-
Notifications
You must be signed in to change notification settings - Fork 40
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