Closed daryllimyt closed 1 month ago
all
isolated
asyncio.gather
GatheringTaskGroup
parallel
sequential
batched
returns
DSLInput
workflow/service.py
workflow/definitions.py
workflow/executions.py
title: Parent workflow description: Test child workflow entrypoint: ref: parent inputs: data: [1, 2, 3, 4, 5, 6, 7] actions: - ref: parent for_each: ${{ for var.x in INPUTS.data }} action: core.workflow.execute args: workflow_id: <<child workflow id>> loop_strategy: parallel fail_strategy: isolated batch_size: 3 trigger_inputs: number: ${{ var.x }}
Features
all
andisolated
fail strategies usingasyncio.gather
/GatheringTaskGroup
parallel
,sequential
, andbatched
loop strategiesreturns
key forDSLInput
. Pass an expression to define the return value of the workflow.Changes
workflow/service.py
intoworkflow/definitions.py
andworkflow/executions.py
Testing
Example usage
Todos