Neil Natarajan
08/08/2022, 5:26 PMNeil Natarajan
08/08/2022, 5:27 PMdask_executor: DaskExecutor = DaskExecutor(address=client_address)
Neil Natarajan
08/08/2022, 5:28 PMconnecting to an existing Dask cluster at tcp:....
and then it gets stuckNeil Natarajan
08/08/2022, 5:30 PMdask_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 taskAnna Geller