Moe
08/23/2023, 1:18 PM| ERROR | GlobalEventLoopThread | prefect._internal.concurrency - Service 'EventsWorker' failed to process item (Event(occurred=DateTime(2023, 8, 23, 13, 15, 6, 960254, tzinfo=Timezone('+00:00')), event='prefect.task-run.Running', resource=Resource(__root__={'prefect.resource.id': 'prefect.task-run.b353993f-c297-4745-941f-0ed69a89942c', 'prefect.resource.name': 'save_to_stg-0', 'prefect.state-message': '', 'prefect.state-name': 'Running', 'prefect.state-timestamp': '2023-08-23T13:15:06.960254+00:00', 'prefect.state-type': 'RUNNING'}), related=[RelatedResource(__root__={'prefect.resource.id': 'prefect.flow-run.5ef22b18-2b29-43d2-8acd-fd0a21a2b580', 'prefect.resource.role': 'flow-run', 'prefect.resource.name': 'electric-chowchow'}), RelatedResource(__root__={'prefect.resource.id': 'prefect.flow.a10e3692-66e9-436d-9abc-0a1e0a92dd75', 'prefect.resource.role': 'flow', 'prefect.resource.name': 'wd-okta-main-flow'})], payload={'intended': {'from': 'PENDING', 'to': 'RUNNING'}, 'initial_state': {'type': 'PENDING', 'name': 'Pending', 'message': ''}, 'validated_state': {'type': 'RUNNING', 'name': 'Running', 'message': ''}}, id=UUID('18b7d97d-f796-4e95-93fc-612b2cf0ec1b'), follows=UUID('8f3fb9d2-eb1c-49e2-a092-8c97203af4a5')), <_contextvars.Context object at 0x000002573D64D080>)
Traceback (most recent call last):
File "C:\Users\maung\AppData\Roaming\Python\Python310\site-packages\prefect\_internal\concurrency\services.py", line 150, in _main_loop
await self._handle(item)
File "C:\Users\maung\AppData\Roaming\Python\Python310\site-packages\prefect\events\worker.py", line 41, in _handle
await self._client.emit(event)
File "C:\Users\maung\AppData\Roaming\Python\Python310\site-packages\prefect\events\clients.py", line 22, in emit
return await self._emit(event)
File "C:\Users\maung\AppData\Roaming\Python\Python310\site-packages\prefect\events\clients.py", line 172, in _emit
assert self._websocket
AssertionError
Marvin
08/23/2023, 1:18 PMMoe
08/23/2023, 1:19 PMJake Kaplan
08/23/2023, 1:41 PMMoe
08/23/2023, 2:06 PMFinished in state Completed('All states completed.')
09:40:26 AM
prefect.flow_runs
An error occurred while monitoring flow run 'af6a2646-1e53-4781-80ed-f7061588feab'. The flow run will not be marked as failed, but an issue may have occurred.
Traceback (most recent call last):
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\prefect\workers\base.py", line 834, in _submit_run_and_capture_errors
result = await self.run(
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\prefect\workers\process.py", line 177, in run
process = await run_process(
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\prefect\utilities\processutils.py", line 273, in run_process
await consume_process_output(
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\prefect\utilities\processutils.py", line 287, in consume_process_output
async with anyio.create_task_group() as tg:
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\anyio\_backends\_asyncio.py", line 597, in __aexit__
raise exceptions[0]
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\prefect\utilities\processutils.py", line 305, in stream_text
async for item in source:
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\anyio\abc\_streams.py", line 34, in __anext__
return await self.receive()
File "C:\Users\rsam.DENTALCORP\AppData\Roaming\Python\Python310\site-packages\anyio\streams\text.py", line 46, in receive
decoded = self._decoder.decode(chunk)
File "C:\Program Files\Python310\lib\codecs.py", line 322, in decode
(result, consumed) = self._buffer_decode(data, self.errors, final)
UnicodeDecodeError: 'utf-8' codec can't decode byte 0xe9 in position 5394: invalid continuation byte