Another orion question im now playing with deployments but t

Question

Another orion question im now playing with deployments but the runs dont seem to be executing correctly I m seeing ```08 01 52 893 | Submitting flow run f37fba9f 4280 431d 9f43 889e53192f24 08 01 52 894 | Completed submission of flow run f37fba9f 4280 431d 9f43 889e53192f24 08 01 52 901 | Finished monitoring for late runs 08 01 54 187 | Flow run f37fba9f 4280 431d 9f43 889e53192f24 exited with exception KeyError main ```

Lawrence Finn · Answer

my deployment ```from prefect deployments import DeploymentSpec from prefect orion schemas schedules import IntervalSchedule from datetime import timedelta note that deployment names are stored and referenced as lt flow name gt lt deployment name gt DeploymentSpec flow location= Users lawrencefinn orion example flow py name= my first deployment parameters= nums 1 2 3 4 schedule=IntervalSchedule interval=timedelta minutes=1 ```

Lawrence Finn · Answer

my flow ```from prefect import flow task from prefect executors import DaskExecutor SequentialExecutor task def say it stuff print f Saying stuff flow executor=DaskExecutor cluster kwargs= n workers 4 threads per worker 1 def my favorite function say it hello return 0 if name == main my favorite function ```

Lawrence Finn · Answer

I also see things like ```08 06 53 106 | Completed submission of flow run bb8c741e da03 4746 9b7b 57970c425745 Exception in callback SubprocessStreamProtocol pipe data received 1 b EXCEPTION 8 XCEPTION 81 n handle lt Handle SubprocessStreamProtocol pipe data received 1 b EXCEPTION 8 XCEPTION 81 n gt Traceback most recent call last File Users lawrencefinn pyenv versions 3 8 5 lib python3 8 asyncio events py line 81 in run self context run self callback self args File Users lawrencefinn pyenv versions 3 8 5 lib python3 8 asyncio subprocess py line 73 in pipe data received reader feed data data File Users lawrencefinn pyenv versions 3 8 5 lib python3 8 asyncio streams py line 472 in feed data assert not self eof feed data after feed eof AssertionError feed data after feed eof```

Anna Geller · Answer

I tried to reproduce using the same flow file you shared I also got KeyError main when a flow is scheduled and it uses Dask executor I tried it with both once with and once without main ```if name == main my favorite function ``` But when removing the executor it works fine with the deployment Btw your flow doesn t have a flow name on the flow decorator and your deployment specifies parameters that you don t use in your flow this shouldn t be the problem here but just to let you know Thanks for checking and reporting that

Lawrence Finn · Answer

ah dask causes the issue got it

Lawrence Finn · Answer

does orion get rid of the agent model

Anna Geller · Answer

Agents still exist in Orion but they are no longer required to run your flows Agents will only be required for automatically scheduled API triggered deployment runs

Zanie · Answer

This will work if you disable subprocesses for the dask workers `DaskExecutor cluster kwargs=dict processes=False ` well investigate a fix though