Clone the repo.
The deployment uses a working queue default_work_queue
:
prefect deployment build --name flow_function_using_pool -q default_work_queue flows.py:flow_function_using_pool
The concurrency limit is set to 1 when applying the flow:
prefect deployment apply --limit 1 flow_function_using_pool-deployment.yaml
Set the logging level to debug:
prefect config set PREFECT_LOGGING_LEVEL=DEBUG
Start the agent on the local machine
prefect agent start -q 'default_work_queue'
Start the server on a separate shell
prefect server start
To test the issue, trigger the execution of flow_function_using_pool
with some dummy values (e.g. [1,2,3]
)