Lukasz Mentel
01/21/2021, 7:25 PMcompute_cop
which has two dependencies, and when I try to replicate that with Flow.add_edge()
I can only specify a single key
to pass the data between tasks. Does anyone know how to get solve or get around this?alex
01/21/2021, 7:33 PMcop.set_upstream([task1, task2, ...])
to set dependencies. But if result
and power
are the dependencies you're referring to, prefect should automatically be able to identify them as dependencies since they are inputs to the compute_cop
task. You can use flow.visualize()
to see the dag and verify the dependencies.Lukasz Mentel
01/21/2021, 7:49 PMset_upstream
seems to be a good suggestion since it's a Task
method but it also takes an optional flow
parameter. I'll give it go, thanks!Zanie
with Flow ….
you don’t need to provide it.Lukasz Mentel
01/21/2021, 7:55 PMflow = Flow(myflow)
flow.add_task(fetch_dataframe)
...
flow.set_dependencies()
can handle what I wanted to do 🙂