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