-
Notifications
You must be signed in to change notification settings - Fork 41
Closed
Labels
Description
The ujson library that orquesta uses major upgraded on Mar 8, 2020. But it doesn't compatible with current Orquesta.
(c.f. https://pypi.org/project/ujson/#history)
Following code is am example to confirm it.
from orquesta import conducting
from orquesta.specs import native as native_specs
from orquesta import statuses
from orquesta.utils import jsonify as json_util
wf_def = """
version: 1.0
vars:
- xs:
- fee
tasks:
task1:
with: <% ctx(xs) %>
action: core.echo message=<% item() %>
"""
spec = native_specs.WorkflowSpec(wf_def)
conductor = conducting.WorkflowConductor(spec)
conductor.request_workflow_status(statuses.RUNNING)
actual_tasks = conductor.get_next_tasks()
json_util.deepcopy(actual_tasks)


