Tanishq Hooda
08/14/2023, 8:31 AM08:00:07.100 | ERROR | GlobalEventLoopThread | prefect._internal.concurrency - Service 'EventsWorker' failed to process item (Event(occurred=DateTime(2023, 8, 14, 8, 0, 7, 99125, tzinfo=Timezone('Etc/UTC')), event='prefect.block.kubernetes-job.get_batch_client.called', resource=Resource(__root__={'prefect.resource.id': 'prefect.block-document.my-id', 'prefect.resource.name': 'kubernetes-block'}), related=[RelatedResource(__root__={'prefect.resource.id': 'prefect.block-type.kubernetes-job', 'prefect.resource.role': 'block-type'})], payload={}, id=UUID('my-id'), follows=None), <Context object at 0x7f11cdd71e40>)
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/prefect/_internal/concurrency/services.py", line 152, in _main_loop
await self._handle(item)
File "/usr/local/lib/python3.9/site-packages/prefect/events/worker.py", line 41, in _handle
await self._client.emit(event)
File "/usr/local/lib/python3.9/site-packages/prefect/events/clients.py", line 22, in emit
return await self._emit(event)
File "/usr/local/lib/python3.9/site-packages/prefect/events/clients.py", line 172, in _emit
assert self._websocket
AssertionError
Moe
08/22/2023, 8:38 PMTanishq Hooda
08/23/2023, 8:49 AMMoe
08/23/2023, 1:02 PMEmil Christensen
08/23/2023, 3:18 PMService 'EventsWorker' failed to process item
error is unrelated to flows stuck in Pending. The reason why is that the events worker is only in charge of sending events to Prefect. Flow run states do not depend on events. Most likely there is another cause.Moe
08/23/2023, 4:05 PM