Hrm, I've got a task that just never seems to terminate? Everything finishes fine but I always have to manually set it as

Successful

. I've tried setting Reference tasks after the Flow def, I'd tried making a task that raises

signals.SUCCESS()

and is downstream from the two main tasks (and I've tried setting the trigger to be

all_finished

), nothing seems to work. The main element of it is is two mapped tasks.

@matta were you able to resolve it? I am facing the same issue with a simple normal task...

@Felix Vemmer Not sure if this is relevant to your case, but switching from Dask Threads (in the Dask Executor) from Processes fixed it.