Question - in a simple local flow run, no parallelism involved, is there a way to make sure the flow run will always execute in some order ? (this helps for an ML reproducibility use-case I am thinking of … )

Hi @Marwan Sarieddine - yes, you can explicitly set the ordering of tasks using the

upstream_tasks

kwarg to a copy of the Task instance. You can read more about

upstream tasks

here: https://docs.prefect.io/api/latest/core/task.html#task-2

Hi @nicholas - thanks for the quick response - will take a look

@Marwan Sarieddine - theoretically, yes, but you can ensure this by including

upstream_tasks=[f1]

in the constructor for

task2a

like this:

with Flow("test-flow") as flow:
    f1 = task1a()
    task1b(f1)
    g1 = task2a(upstream_tasks=[f1])
    task2b(g1)

oh ok - gotcha

You can see this in the flow DAG

yep - thank you !