Open
Description
The below workflow didn't execute Nested6
for subsequent items in listed
, if it fails for any item in listed
. Basically if last running concurrent nested task is failed than it marks the staged task as completed and didn't pick the next task from staged items.
I have proposed a change which worked for me in a PR #221. Where I have update the TASK_STATE_MACHINE_DATA
map for current state to new state for event events.ACTION_FAILED_TASK_DORMANT_ITEMS_INCOMPLETE: statuses.RUNNING
.
---
version: "1.0"
description: "Workflow desc"
input:
- "nested"
- "break_on"
- "l_c"
- "listed"
tasks:
Start:
action: "core.noop"
next:
- when: "<% succeeded() %>"
do: "Nested6"
Nested6:
action: "core.local cmd='exit 1'"
input:
b: "<% item(list_i) %>"
l_c: "<% ctx().l_c %>"
next:
- when: "<% succeeded() %>"
do: "Join11"
- when: "<% failed() %>"
do: "Join12"
with:
items: list_i in <% ctx(listed) %>
concurrency: 1
Join11:
action: "core.noop"
next:
- when: "<% failed() %>"
do: "fail"
join: "all"
Join12:
action: "core.noop"
next:
- when: "<% failed() %>"
do: "fail"
join: "all"
Metadata
Metadata
Assignees
Labels
No labels