This message was deleted

Question

Deepanshu Aggarwal · Answer

Encountered exception during execution Traceback most recent call last File usr local lib python3 10 site packages httpx transports default py line 60 in map httpcore exceptions yield File usr local lib python3 10 site packages httpx transports default py line 353 in handle async request resp = await self pool handle async request req File usr local lib python3 10 site packages httpcore async connection pool py line 253 in handle async request raise exc File usr local lib python3 10 site packages httpcore async connection pool py line 237 in handle async request response = await connection handle async request request File usr local lib python3 10 site packages httpcore async connection py line 90 in handle async request return await self connection handle async request request File usr local lib python3 10 site packages httpcore async http11 py line 112 in handle async request raise exc File usr local lib python3 10 site packages httpcore async http11 py line 91 in handle async request = await self receive response headers kwargs File usr local lib python3 10 site packages httpcore async http11 py line 155 in receive response headers event = await self receive event timeout=timeout File usr local lib python3 10 site packages httpcore async http11 py line 205 in receive event raise RemoteProtocolError msg httpcore RemoteProtocolError Server disconnected without sending a response The above exception was the direct cause of the following exception Traceback most recent call last File usr local lib python3 10 site packages prefect engine py line 1247 in orchestrate task run result = await run sync task fn args kwargs File usr local lib python3 10 site packages prefect utilities asyncutils py line 68 in run sync in worker thread return await <http anyio to|anyio to> thread run sync call cancellable=True File usr local lib python3 10 site packages anyio to thread py line 31 in run sync return await get asynclib run sync in worker thread File usr local lib python3 10 site packages anyio backends asyncio py line 937 in run sync in worker thread return await future File usr local lib python3 10 site packages anyio backends asyncio py line 867 in run result = context run func args File opt prefect flows process sso integrations flows sso flow py line 85 in sso token executor output = run deployment File usr local lib python3 10 site packages prefect utilities asyncutils py line 197 in coroutine wrapper return run async from worker thread async fn args kwargs File usr local lib python3 10 site packages prefect utilities asyncutils py line 148 in run async from worker thread return anyio from thread run call File usr local lib python3 10 site packages anyio from thread py line 49 in run return asynclib run async from thread func args File usr local lib python3 10 site packages anyio backends asyncio py line 970 in run async from thread return f result File usr local lib python3 10 concurrent futures base py line 458 in result return self get result File usr local lib python3 10 concurrent futures base py line 403 in get result raise self exception File usr local lib python3 10 site packages prefect client utilities py line 47 in with injected client return await fn args kwargs File usr local lib python3 10 site packages prefect deployments py line 131 in run deployment flow run = await client read flow run flow run id File usr local lib python3 10 site packages prefect client orion py line 1443 in read flow run response = await self client get f flow runs flow run id File usr local lib python3 10 site packages httpx client py line 1757 in get return await self request File usr local lib python3 10 site packages httpx client py line 1533 in request return await self send request auth=auth follow redirects=follow redirects File usr local lib python3 10 site packages prefect client base py line 160 in send await super send args kwargs File usr local lib python3 10 site packages httpx client py line 1620 in send response = await self send handling auth File usr local lib python3 10 site packages httpx client py line 1648 in send handling auth response = await self send handling redirects File usr local lib python3 10 site packages httpx client py line 1685 in send handling redirects response = await self send single request request File usr local lib python3 10 site packages httpx client py line 1722 in send single request response = await transport handle async request request File usr local lib python3 10 site packages httpx transports default py line 352 in handle async request with map httpcore exceptions File usr local lib python3 10 contextlib py line 153 in exit self gen throw typ value traceback File usr local lib python3 10 site packages httpx transports default py line 77 in map httpcore exceptions raise mapped exc message from exc httpx RemoteProtocolError Server disconnected without sending a response

Christopher Boyd · Answer

what s the server in this case

Christopher Boyd · Answer

Also would you be able to move your tracebacks into the thread

Deepanshu Aggarwal · Answer

i think i deleted it by mistake

Deepanshu Aggarwal · Answer

```Crash detected Execution was interrupted by an unexpected exception Traceback most recent call last File usr local lib python3 10 asyncio selector events py line 916 in write n = self sock send data BrokenPipeError Errno 32 Broken pipe The above exception was the direct cause of the following exception Traceback most recent call last File usr local lib python3 10 site packages httpcore exceptions py line 10 in map exceptions yield File usr local lib python3 10 site packages httpcore backends asyncio py line 33 in read return await self stream receive max bytes=max bytes File usr local lib python3 10 site packages anyio backends asyncio py line 1274 in receive raise self protocol exception anyio BrokenResourceError During handling of the above exception another exception occurred Traceback most recent call last File usr local lib python3 10 site packages httpx transports default py line 60 in map httpcore exceptions yield File usr local lib python3 10 site packages httpx transports default py line 353 in handle async request resp = await self pool handle async request req File usr local lib python3 10 site packages httpcore async connection pool py line 253 in handle async request raise exc File usr local lib python3 10 site packages httpcore async connection pool py line 237 in handle async request response = await connection handle async request request File usr local lib python3 10 site packages httpcore async connection py line 90 in handle async request return await self connection handle async request request File usr local lib python3 10 site packages httpcore async http11 py line 112 in handle async request raise exc File usr local lib python3 10 site packages httpcore async http11 py line 91 in handle async request = await self receive response headers kwargs File usr local lib python3 10 site packages httpcore async http11 py line 155 in receive response headers event = await self receive event timeout=timeout File usr local lib python3 10 site packages httpcore async http11 py line 191 in receive event data = await self network stream read File usr local lib python3 10 site packages httpcore backends asyncio py line 30 in read with map exceptions exc map File usr local lib python3 10 contextlib py line 153 in exit self gen throw typ value traceback File usr local lib python3 10 site packages httpcore exceptions py line 14 in map exceptions raise to exc exc httpcore ReadError The above exception was the direct cause of the following exception httpx ReadError```

Deepanshu Aggarwal · Answer

im using aws eks to host my orion server with our own postgresql

Christopher Boyd · Answer

that was a concern I had that disconnected by server says that it was not a graceful disconnect possibly too many connections are being opened or a connection being opened and not responded to so the server disconnects the remote end forcefully e g with a RST instead of a FIN

Deepanshu Aggarwal · Answer

yes we are trying to make a lot of connections but is there a work around for it any method to maintain a large number of connections

Christopher Boyd · Answer

that would be at your database

Christopher Boyd · Answer

you would either need to be able to handle many connections at the database ensure that you aren t opening and not closing connections at the flow and potentially organizing scheduling them in a way that distributes the connections

Christopher Boyd · Answer

also are you connecting from inside the same cluster to the service of postgres or outbound to an external source that is not located in the same cluster

Deepanshu Aggarwal · Answer

its outside the cluster we have postgre running on rds but inside the same virtual network

Deepanshu Aggarwal · Answer

how to close connections at the flow