Ankit
07/15/2020, 6:01 PMDask executor
along with prefect ui+server. My prefect ui+server and dask are all on docker containers via a docker-compose file, belonging to the same network. I start up my agent, which is a local agent on a docker container and use flow.register()
to register my flow. When I try to set the executor in flow.environment , I get an error. Not sure how to proceed here.
This is how I am setting the dask executor:
client = Client("scheduler:8786")
dask_executor = DaskExecutor(address=client.scheduler.address)
flow.environment = LocalEnvironment(executor=dask_executor)
flow.register()
The error that I get is :
flow.environment = LocalEnvironment(executor=dask_executor)
TypeError: __init__() got an unexpected keyword argument 'executor'
I am also getting a warning:
warnings.warn(version_module.VersionMismatchWarning(msg[0]["warning"]))
josh
07/15/2020, 6:02 PMAnkit
07/15/2020, 6:03 PMjosh
07/15/2020, 6:05 PMAnkit
07/15/2020, 6:08 PM