https://prefect.io logo
Title
n

Neil Natarajan

08/08/2022, 5:26 PM
Hi! Does prefect support running Flows from within Prefect Tasks? What is the best syntax for running a flow of flows with the free offering
currently I am trying to connect to an existing local dask executor by doing
dask_executor: DaskExecutor = DaskExecutor(address=client_address)
On certain substages of my flow however I see something along the lines of
connecting to an existing Dask cluster at tcp:....
and then it gets stuck
dask_executor: DaskExecutor = DaskExecutor(address=client_address)
    result = flow.run(
        executor=dask_executor,
        parameters={
...
...
this is how I am trying to run a flow from within a prefect task
a

Anna Geller

08/09/2022, 5:17 PM
Not possible, but you can call flows from flows in 2.0 with the Subflows pattern
:thank-you: 1