task with join: all starts without waiting for all the previous task completed when there is a loop
Nobody has claimed this yet.
Assessment
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Newbie friendliness
- 35/100
Research direction
Start by running the supplied YAML workflow with three parallel tasks that can fail and loop back to the parallel branch. Trace how the join-all task is tracked across loop iterations and compare each invocation's context values. Done means determining whether the second iteration's early join is a bug or a documented graph-workflow constraint.
Written by the indexing model from the issue text.
Description
I made a workflow having 3 parallel tasks each of which randomly fails, along with a task join all of them.
If all of the parallel tasks success, then the workflow will end. Otherwise, the workflow steps back to rerun the parallel tasks. The yaml code is as followed:
version: 1.0
description: loop parallel workflow.
input:
- x: {}
- y: {}
- z: {}
output:
- data:
x: <% ctx().x %>
y: <% ctx().y %>
z: <% ctx().z %>
tasks:
entrypoint:
next:
- do: parallel
parallel:
action: core.noop
next:
- do: random_failure1,random_failure2, random_failure3
random_failure1:
action: my_pack.random_failure
next:
- publish: x=<% result() %>
do: count_failure
random_failure2:
action: my_pack.random_failure
next:
- publish: y=<% result() %>
do: count_failure
random_failure3:
action: my_pack.random_failure
next:
- publish: z=<% result() %>
do: count_failure
count_failure:
join: all
action: my_pack.count_failure
input:
- x=<% ctx(x) %>
- y=<% ctx(y) %>
- z=<% ctx(z) %>
next:
- when: <% result().failure_count > 0 %>
do: tasks
In the first trial, the count_failure task starts after all of the 3 parallel task end and gets the context x, y, z updated by parallel tasks. Let s call the context x1, y1, z1.
However, in the second loop, the count_failure task starts after any of the 3 parallel task end. Assuming that random_failure1 ends first and count_failure will start immediately after that, with the context to be x2(updated by random_failure1), y1(not updated), z1(not updated). And when random_failure2 ends, another count_failure task starts with input like x2, y2, z1.
I am expecting the count_failure task also starts starts after all of the 3 parallel task end in the second loop, with input updated as x2, y2, z2.
Is this a bug, or the constraint of the graph based workflow in orquesta?
- Dominant language
- Python
- Stars
- 111
- Forks
- 44
- PR merge metrics
- No merged PRs in 30d
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
More from StackStorm/orquesta
-
Difficulty 3/5 1-2 days Newbie friendliness 48/100
StackStorm/orquesta#275 ·
-
Difficulty 3/5 1-2 days Newbie friendliness 35/100
StackStorm/orquesta#274 ·
-
Difficulty 5/5 Over a week Newbie friendliness 25/100
StackStorm/orquesta#272 ·
-
Difficulty 3/5 1-2 days Newbie friendliness 45/100
StackStorm/orquesta#268 ·
-
Vague error Open
Difficulty 2/5 1-3 hours Newbie friendliness 45/100
StackStorm/orquesta#265 · 1 comment ·
All issues in StackStorm/orquesta
Similar issues
-
triage/confirmed
Difficulty 2/5 1-3 hours Newbie friendliness 88/100
agentscope-ai/agentscope#2775 ·
-
comp/desktop P3 type/bug
Difficulty 1/5 Under an hour Newbie friendliness 92/100
NousResearch/hermes-agent#118866 ·
-
bug
Difficulty 1/5 Under an hour Newbie friendliness 90/100
apache/cloudstack#14222 ·
-
Difficulty 2/5 1-3 hours Newbie friendliness 76/100
-
bug
Difficulty 2/5 1-3 hours Newbie friendliness 82/100