Where does the code the

if __name__ == "__main__":

block on code run. Does it run on the Agent? I am working on setting up a streaming flow with GCP Cloudrun jobs for the worker pool and am curious sync this part of the flow is continuous?

can you explain what you mean by this?

Where does the code the

if __name__ == "__main__":

block on code run

if you mean you have something like this that you've created a deployment from

@flow
def my_flow():
   pass

if __name__ == "__main__":
   my_flow()

in your local flow file, that

if __name__ == "__main__":

block doesn't actually run when your agent pulls -> submits your deployment flow run the prefect engine will call your flow with the parameters (default, or the ones you provided), as the

flow

-decorated function was defined in your local flow file when you created the deployment from it - does that make sense?

So in my case instead of my_flow()

the while loop pattern would work if you're running the flow as a script on some machine, but it doesn't work directly if you've created a deployment and are deferring the submission of the flow run to the Prefect engine, since the prefect engine will call your entrypoint flow directly with the appropriate parameters (which means you can't directly add logic like the while loop on top of the deployment entrypoint) is it possible in your setup to have your publisher post directly to

create_flow_run_from_deployment

(via run_deployment)? that way you could let the prefect API act as the listener, triggering a new flow run each time some event comes through instead of having a while loop