Mike B
09/16/2024, 10:05 PMMarvin
09/16/2024, 10:05 PMNate
09/16/2024, 10:07 PMfuture = some_task.submit()
downstream_task.submit(wait_for=[future])
etc, then this is functionally the same thing as
result = some_task()
downstream_task(wait_for=[result])
Mike B
09/16/2024, 10:11 PMNate
09/16/2024, 10:13 PMtask_runner=SequentialTaskRunner
from your @flow
this is a common gotcha, but if you weren't using submit / map, then you weren't using the task runnerMike B
09/16/2024, 10:13 PM