Faheem Khan
11/06/2022, 11:34 PMCarlo
11/07/2022, 2:17 PMBianca Hoch
11/07/2022, 5:46 PMFaheem Khan
11/07/2022, 11:10 PMprefect-agent_1 | 23:07:49.438 | DEBUG | prefect.agent - Checking for flow runs...
prefect-agent_1 | 23:07:49.447 | ERROR | prefect.agent -
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/asyncio/selector_events.py", line 854, in _read_ready__data_received
prefect-agent_1 | data = self._sock.recv(self.max_size)
prefect-agent_1 | ConnectionResetError: [Errno 104] Connection reset by peer
prefect-agent_1 |
prefect-agent_1 | The above exception was the direct cause of the following exception:
prefect-agent_1 |
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_exceptions.py", line 8, in map_exceptions
prefect-agent_1 | yield
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/backends/asyncio.py", line 33, in read
prefect-agent_1 | return await self._stream.receive(max_bytes=max_bytes)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/anyio/_backends/_asyncio.py", line 1274, in receive
prefect-agent_1 | raise self._protocol.exception
prefect-agent_1 | anyio.BrokenResourceError
prefect-agent_1 |
prefect-agent_1 | During handling of the above exception, another exception occurred:
prefect-agent_1 |
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 60, in map_httpcore_exceptions
prefect-agent_1 | yield
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 353, in handle_async_request
prefect-agent_1 | resp = await self._pool.handle_async_request(req)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection_pool.py", line 253, in handle_async_request
prefect-agent_1 | raise exc
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection_pool.py", line 237, in handle_async_request
prefect-agent_1 | response = await connection.handle_async_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection.py", line 90, in handle_async_request
prefect-agent_1 | return await self._connection.handle_async_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 105, in handle_async_request
prefect-agent_1 | raise exc
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 84, in handle_async_request
prefect-agent_1 | ) = await self._receive_response_headers(**kwargs)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 148, in _receive_response_headers
prefect-agent_1 | event = await self._receive_event(timeout=timeout)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 177, in _receive_event
prefect-agent_1 | data = await self._network_stream.read(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/backends/asyncio.py", line 30, in read
prefect-agent_1 | with map_exceptions(exc_map):
prefect-agent_1 | File "/usr/local/lib/python3.10/contextlib.py", line 153, in exit
prefect-agent_1 | self.gen.throw(typ, value, traceback)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_exceptions.py", line 12, in map_exceptions
prefect-agent_1 | raise to_exc(exc)
prefect-agent_1 | httpcore.ReadError
prefect-agent_1 |
prefect-agent_1 | The above exception was the direct cause of the following exception:
prefect-agent_1 |
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/prefect/agent.py", line 154, in get_and_submit_flow_runs
prefect-agent_1 | queue_runs = await self.client.get_runs_in_work_queue(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/prefect/client/orion.py", line 759, in get_runs_in_work_queue
prefect-agent_1 | response = await self._client.post(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1842, in post
prefect-agent_1 | return await self.request(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1527, in request
prefect-agent_1 | return await self.send(request, auth=auth, follow_redirects=follow_redirects)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/prefect/client/base.py", line 159, in send
prefect-agent_1 | await super().send(*args, **kwargs)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1614, in send
prefect-agent_1 | response = await self._send_handling_auth(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1642, in _send_handling_auth
prefect-agent_1 | response = await self._send_handling_redirects(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1679, in _send_handling_redirects
prefect-agent_1 | response = await self._send_single_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1716, in _send_single_request
prefect-agent_1 | response = await transport.handle_async_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 352, in handle_async_request
prefect-agent_1 | with map_httpcore_exceptions():
prefect-agent_1 | File "/usr/local/lib/python3.10/contextlib.py", line 153, in exit
prefect-agent_1 | self.gen.throw(typ, value, traceback)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 77, in map_httpcore_exceptions
prefect-agent_1 | raise mapped_exc(message) from exc
prefect-agent_1 | httpx.ReadError
prefect-agent_1 | 23:07:54.465 | DEBUG | prefect.agent - Checking for flow runs...prefect-agent_1 | 23:11:21.748 | DEBUG | prefect.agent - Checking for flow runs...
prefect-agent_1 | 23:11:21.755 | ERROR | prefect.agent -
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/asyncio/selector_events.py", line 916, in write
prefect-agent_1 | n = self._sock.send(data)
prefect-agent_1 | BrokenPipeError: [Errno 32] Broken pipe
prefect-agent_1 |
prefect-agent_1 | The above exception was the direct cause of the following exception:
prefect-agent_1 |
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_exceptions.py", line 8, in map_exceptions
prefect-agent_1 | yield
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/backends/asyncio.py", line 33, in read
prefect-agent_1 | return await self._stream.receive(max_bytes=max_bytes)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/anyio/_backends/_asyncio.py", line 1274, in receive
prefect-agent_1 | raise self._protocol.exception
prefect-agent_1 | anyio.BrokenResourceError
prefect-agent_1 |
prefect-agent_1 | During handling of the above exception, another exception occurred:
prefect-agent_1 |
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 60, in map_httpcore_exceptions
prefect-agent_1 | yield
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 353, in handle_async_request
prefect-agent_1 | resp = await self._pool.handle_async_request(req)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection_pool.py", line 253, in handle_async_request
prefect-agent_1 | raise exc
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection_pool.py", line 237, in handle_async_request
prefect-agent_1 | response = await connection.handle_async_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection.py", line 90, in handle_async_request
prefect-agent_1 | return await self._connection.handle_async_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 105, in handle_async_request
prefect-agent_1 | raise exc
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 84, in handle_async_request
prefect-agent_1 | ) = await self._receive_response_headers(**kwargs)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 148, in _receive_response_headers
prefect-agent_1 | event = await self._receive_event(timeout=timeout)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_async/http11.py", line 177, in _receive_event
prefect-agent_1 | data = await self._network_stream.read(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/backends/asyncio.py", line 30, in read
prefect-agent_1 | with map_exceptions(exc_map):
prefect-agent_1 | File "/usr/local/lib/python3.10/contextlib.py", line 153, in exit
prefect-agent_1 | self.gen.throw(typ, value, traceback)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpcore/_exceptions.py", line 12, in map_exceptions
prefect-agent_1 | raise to_exc(exc)
prefect-agent_1 | httpcore.ReadError
prefect-agent_1 |
prefect-agent_1 | The above exception was the direct cause of the following exception:
prefect-agent_1 |
prefect-agent_1 | Traceback (most recent call last):
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/prefect/agent.py", line 154, in get_and_submit_flow_runs
prefect-agent_1 | queue_runs = await self.client.get_runs_in_work_queue(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/prefect/client/orion.py", line 759, in get_runs_in_work_queue
prefect-agent_1 | response = await self._client.post(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1842, in post
prefect-agent_1 | return await self.request(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1527, in request
prefect-agent_1 | return await self.send(request, auth=auth, follow_redirects=follow_redirects)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/prefect/client/base.py", line 159, in send
prefect-agent_1 | await super().send(*args, **kwargs)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1614, in send
prefect-agent_1 | response = await self._send_handling_auth(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1642, in _send_handling_auth
prefect-agent_1 | response = await self._send_handling_redirects(
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1679, in _send_handling_redirects
prefect-agent_1 | response = await self._send_single_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1716, in _send_single_request
prefect-agent_1 | response = await transport.handle_async_request(request)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 352, in handle_async_request
prefect-agent_1 | with map_httpcore_exceptions():
prefect-agent_1 | File "/usr/local/lib/python3.10/contextlib.py", line 153, in exit
prefect-agent_1 | self.gen.throw(typ, value, traceback)
prefect-agent_1 | File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 77, in map_httpcore_exceptions
prefect-agent_1 | raise mapped_exc(message) from exc
prefect-agent_1 | httpx.ReadErrorBianca Hoch
11/11/2022, 4:59 PMFaheem Khan
11/15/2022, 8:35 AM