https://prefect.io logo
m

Moe

08/23/2023, 2:36 PM
Anyone see this error before? I am seeing this in the UI logs after the flow run completes successfully. How to resolve?
Copy code
An error occurred while monitoring flow run '939028cd-0595-4b3c-bf4a-3c9b123d1e60'. The flow run will not be marked as failed, but an issue may have occurred.
Traceback (most recent call last):
  File "D:\Prefect\.venv\lib\site-packages\prefect\workers\base.py", line 834, in _submit_run_and_capture_errors
    result = await self.run(
  File "D:\Prefect\.venv\lib\site-packages\prefect\workers\process.py", line 176, in run
    process = await run_process(
  File "D:\Prefect\.venv\lib\site-packages\prefect\utilities\processutils.py", line 273, in run_process
    await consume_process_output(
  File "D:\Prefect\.venv\lib\site-packages\prefect\utilities\processutils.py", line 287, in consume_process_output
    async with anyio.create_task_group() as tg:
  File "D:\Prefect\.venv\lib\site-packages\anyio\_backends\_asyncio.py", line 597, in __aexit__
    raise exceptions[0]
  File "D:\Prefect\.venv\lib\site-packages\prefect\utilities\processutils.py", line 305, in stream_text
    async for item in source:
  File "D:\Prefect\.venv\lib\site-packages\anyio\abc\_streams.py", line 34, in __anext__
    return await self.receive()
  File "D:\Prefect\.venv\lib\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 1888: invalid continuation byte
1
s

Serina

08/23/2023, 3:11 PM
Hi @Moe, I believe this may resolve your issue. Want to give that a try? https://github.com/PrefectHQ/prefect/issues/6446#issuecomment-1219553576
m

Moe

08/23/2023, 3:15 PM
@Serina Hi, thanks. I just changed the way I imported my subflows and no longer experience this issue. Not sure why though but before I had:
Copy code
import subflow1

def main_flow():
     subflow1.subflow1()
Changing it to this fixed it.
Copy code
from subflow1 import subflow1

def main_flow():
     subflow1()
s

Serina

08/23/2023, 3:18 PM
Got it, thanks for sharing your before and after! 🙌