I have a custom executor environment PipelineExecutor Pipeli

Question

I have a custom executor environment PipelineExecutor PipelineEnvironment to execute code using my on prem scheduler I m seeing the following error which I m trying to debug ```execute missing 1 required positional argument flow location Traceback most recent call last File usr local bin prefect line 11 in lt module gt sys exit cli File usr local lib python3 6 dist packages click core py line 829 in call return self main args kwargs File usr local lib python3 6 dist packages click core py line 782 in main rv = self invoke ctx File usr local lib python3 6 dist packages click core py line 1259 in invoke return process result sub ctx command invoke sub ctx File usr local lib python3 6 dist packages click core py line 1259 in invoke return process result sub ctx command invoke sub ctx File usr local lib python3 6 dist packages click core py line 1066 in invoke return ctx invoke self callback ctx params File usr local lib python3 6 dist packages click core py line 610 in invoke return callback args kwargs File usr local lib python3 6 dist packages prefect cli execute py line 34 in flow run return execute flow run File usr local lib python3 6 dist packages prefect cli execute py line 99 in execute flow run raise exc File usr local lib python3 6 dist packages prefect cli execute py line 93 in execute flow run environment execute flow TypeError execute missing 1 required positional argument flow location 2020 10 24 04 14 03 330 INFO agent | Process PID 23114 returned non zero exit code``` This error confuses me primarily because I don t see my custom executor anywhere in the stack nor do I understand what was supposed to be passing around location The code runs fine when run locally using `flow run ` ``` 2020 10 24 04 01 44 INFO prefect FlowRunner | Beginning Flow run for test flow 2020 10 24 04 01 44 INFO prefect TaskRunner | Task random number Starting task run 2020 10 24 04 01 49 INFO prefect TaskRunner | Task random number finished task run for task with final state Success 2020 10 24 04 01 49 INFO prefect TaskRunner | Task plus one Starting task run 2020 10 24 04 01 49 INFO prefect TaskRunner | Task plus one finished task run for task with final state Success 2020 10 24 04 01 49 INFO prefect TaskRunner | Task plus two Starting task run 2020 10 24 04 01 49 INFO prefect TaskRunner | Task plus two finished task run for task with final state Success 2020 10 24 04 01 50 INFO prefect TaskRunner | Task plus three Starting task run 2020 10 24 04 01 50 INFO prefect TaskRunner | Task plus three finished task run for task with final state Success 2020 10 24 04 01 50 INFO prefect FlowRunner | Flow run SUCCESS all reference tasks succeeded``` Code is imports removed to save space ``` task name= random number def random number time sleep 5 return random randint 0 100 task name= random number def random number time sleep 5 return random randint 0 100 task name= plus one def plus one x return x + 1 task name= plus two def plus two x return x + 2 task name= plus three def plus three x return x + 3 with Flow test flow environment=LocalEnvironment executor=PipelineExecutor as flow flow = Flow test flow storage=Local environment=PipelineEnvironment plus three bind plus one flow=flow plus two set upstream plus one flow=flow plus two bind plus one flow=flow plus one set upstream random number flow=flow plus one bind random number flow=flow ```