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"
The below workflow didn't execute
Nested6for subsequent items inlisted, if it fails for any item inlisted. 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_DATAmap for current state to new state for eventevents.ACTION_FAILED_TASK_DORMANT_ITEMS_INCOMPLETE: statuses.RUNNING.