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

Arun Giridharan

11/04/2021, 8:13 PM

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

upstream_tasks

to differentiate them?

Kevin Kho

11/04/2021, 8:14 PM

Hey @Arun Giridharan, I think you want something like

Copy code

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

    c = task_two(upstream_tasks=[b])

Arun Giridharan

11/04/2021, 8:15 PM

thanks Kevin!

2 Views

Open in Slack

Previous Next

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.