If I'm running the same task twice in the same flow, is there a way to use

upstream_tasks

to differentiate them?

Hey @Arun Giridharan, I think you want something like

with Flow(..) as flow:
    a = task_one()
    b = task_one()

    c = task_two(upstream_tasks=[b])

thanks Kevin!