Is there a replacement for `upstream_tasks=[result])` in 2.0? I used this in 1.0 when using the Dask...

Sam Garvis

08/24/2022, 4:46 PM

Is there a replacement for

upstream_tasks=[result])

in 2.0? I used this in 1.0 when using the Dask Executor to force a task to wait on another task, but I believe it was taken away in 2.0

✅ 1

Neil Natarajan

08/24/2022, 4:49 PM

it's now

wait_for

✅ 1

Neil Natarajan

08/24/2022, 4:50 PM

subflows are blocking

3 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.