Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

quick question :pray::skin-tone-2:

I built a work queue for Concurrency: `unlimited` It works perfectly fine.
However, when I modify Concurrency into, for example, 3 It failed to run jobs :disappointed:

I only found log in agent
```│ httpx.LocalProtocolError: Invalid input ConnectionInputs.RECV_PING in state ConnectionState.CLOSED                                                                                                       │
│ 07:46:36.643 | ERROR   | prefect.agent - Invalid input ConnectionInputs.SEND_HEADERS in state ConnectionState.CLOSED                                                                                     │
│ Traceback (most recent call last):                                                                                                                                                                       │
│   File "/usr/local/lib/python3.9/site-packages/h2/connection.py", line 224, in process_input                                                                                                             │
│     func, target_state = self._transitions[(self.state, input_)]                                                                                                                                         │
│ KeyError: (&lt;ConnectionState.CLOSED: 3&gt;, &lt;ConnectionInputs.SEND_HEADERS: 0&gt;)                                                                                                                              │
│                                                                                                                                                                                                          │
│ During handling of the above exception, another exception occurred:```
Or I misunderstand the usage of the concurrent usage.

Hey <@U048PGXKZQX> Could you provide some more info about the flow that triggered this error? Specifically a minimum reproducible example of the flow code, Any additional flow configurations (task runner, retries configured, etc/)

endpoints.py

helpler.py

deploy_prefect.py

<@U03B84QJ78A> thanks for the reply.
It fixed after setting to 20.
`3 and 10 will lead to the failed outcome`
Specifically, work queue will show failed and jobs stay pending.
---------------------------------------------------------------------------
No jobs created in k8s.
I could only find the error log like the head of the thread.
---------------------------------------------------------------------------
In terms of 20 passing case, is that anything I should learn about setting this figure?
Thank you very much :man-bowing::skin-tone-2: