DAG replay may inherit RUNNING parallel task from previous execution and stay RUNNING
Author: thyw1Created Mar 16, 2026Updated Sep 17, 2026
Labelsarea/backendarea/frontend
Hi Kestra team,
I encountered an issue when replaying a failed subtask inside a DAG with parallel tasks and wanted to check if this behavior is expected.
Description
When replaying a failed subtask in a DAG, the new execution may remain in RUNNING indefinitely.
It seems that a parallel subtask from the original execution that was already in RUNNING state can be inherited into the new execution with its previous state. Since this task is not actually executing anymore, the DAG task waits indefinitely for it to complete.
This happens inside a DAG with parallel tasks (not using Subflow).
Steps to Reproduce
- Create a DAG with multiple parallel subtasks
- Run the DAG so that several subtasks start executing
- One subtask fails while another parallel subtask remains in
RUNNING - Replay the failed subtask
- The new execution remains in
RUNNING
Observed Behavior
- The replayed subtask executes successfully
- Another parallel subtask from the previous execution remains in
RUNNINGstate - The DAG task waits indefinitely and the execution never completes
Question
Is this expected behavior when replaying a subtask in a DAG, or could this be an issue with how task runs are inherited during replay?
Thanks!
Example Execution
{
"id": "11xL3g9PibCvX13B6v9zHO",
"flowId": "f-20260311095430-wrd4i",
"taskRunList": [
{
"id": "7VYOubPO1msIZKTfEMtSfl",
"taskId": "dag_0",
"state": { "current": "RUNNING" }
},
{
"id": "4l7gZDudDAD8J61VoZz97O",
"taskId": "n_20260311101030_2ztgj",
"state": { "current": "SUCCESS" },
"attempts": [
{ "state": { "current": "FAILED" } },
{ "state": { "current": "SUCCESS" } }
]
},
{
"id": "7PYS6xslwQlG1JBSsvgSCg",
"taskId": "n_20260311101227_982hx",
"state": { "current": "RUNNING" },
"attempts": [
{ "state": { "current": "RUNNING" } }
]
}
],
"state": { "current": "RUNNING" },
"parentId": "5hUSkGWIXvzFBEOo1GCLti"
}
### Environment
- Kestra Version: developSource: kestra-io/kestra