10:04:09.176 | INFO    | prefect.flow_runs.worker - Worker 'ProcessWorker 1d50a06d-4523-4404-99e2-246a9ab4c518' submitting flow run '796a4690-ad27-45a4-ae61-45d405e760f9'
10:04:09.952 | INFO    | prefect.flow_runs.worker - Opening process...
10:04:10.050 | INFO    | prefect.flow_runs.worker - Completed submission of flow run '796a4690-ad27-45a4-ae61-45d405e760f9'
C:\Users\Tim\anaconda3\lib\runpy.py:126: RuntimeWarning: 'prefect.engine' found in sys.modules after import of package 'prefect', but prior to execution of 'prefect.engine'; this may result in unpredictable behaviour
  warn(RuntimeWarning(msg))
10:04:12.270 | INFO    | Flow run 'misty-newt' - Downloading flow code from storage at 'C:\\Users\\Tim\\prefect_training'
10:04:13.780 | INFO    | Flow run 'misty-newt' - Created task run 'fetch_air_quality-0' for task 'fetch_air_quality'
10:04:13.781 | INFO    | Flow run 'misty-newt' - Executing 'fetch_air_quality-0' immediately...
10:04:14.838 | INFO    | Task run 'fetch_air_quality-0' - Finished in state Completed()
10:04:15.393 | INFO    | Flow run 'misty-newt' - Created subflow run 'archetypal-harrier' for flow 'air-quality-stats'
10:04:15.394 | INFO    | Flow run 'archetypal-harrier' - View at <https://app.prefect.cloud/account/ec455b18-0882-4b4a-b18a-64f089b7019b/workspace/e0f9396c-81b3-4b06-8503-f24e47195fb9/flow-runs/flow-run/2fc9473a-919a-4121-ad8e-ec05b191f905>
10:04:15.585 | 10:04:15.819 | ERROR   | asyncio - Exception in callback SubprocessStreamProtocol.pipe_data_received(2, bytearray(b'10:04:15.818 | '))
handle: <Handle SubprocessStreamProtocol.pipe_data_received(2, bytearray(b'10:04:15.818 | '))>
Traceback (most recent call last):
  File "C:\Users\Tim\anaconda3\lib\asyncio\events.py", line 80, in _run
    self._context.run(self._callback, *self._args)
  File "C:\Users\Tim\anaconda3\lib\asyncio\subprocess.py", line 72, in pipe_data_received
    reader.feed_data(data)
  File "C:\Users\Tim\anaconda3\lib\asyncio\streams.py", line 456, in feed_data
    assert not self._eof, 'feed_data after feed_eof'
AssertionError: feed_data after feed_eof
10:04:15.822 | ERROR   | asyncio - Exception in callback SubprocessStreamProtocol.pipe_data_received(2, 
bytearray(b"I...ed in state "))
handle: <Handle SubprocessStreamProtocol.pipe_data_received(2, bytearray(b"I...ed in state "))>
Traceback (most recent call last):
  File "C:\Users\Tim\anaconda3\lib\asyncio\events.py", line 80, in _run
    self._context.run(self._callback, *self._args)
  File "C:\Users\Tim\anaconda3\lib\asyncio\subprocess.py", line 72, in pipe_data_received
    reader.feed_data(data)
  File "C:\Users\Tim\anaconda3\lib\asyncio\streams.py", line 456, in feed_data
    assert not self._eof, 'feed_data after feed_eof'
AssertionError: feed_data after feed_eof
10:04:15.824 | ERROR   | asyncio - Exception in callback SubprocessStreamProtocol.pipe_data_received(2, 
bytearray(b'Completed()\r\n'))
handle: <Handle SubprocessStreamProtocol.pipe_data_received(2, bytearray(b'Completed()\r\n'))>
Traceback (most recent call last):
  File "C:\Users\Tim\anaconda3\lib\asyncio\events.py", line 80, in _run
    self._context.run(self._callback, *self._args)
  File "C:\Users\Tim\anaconda3\lib\asyncio\subprocess.py", line 72, in pipe_data_received
    reader.feed_data(data)
  File "C:\Users\Tim\anaconda3\lib\asyncio\streams.py", line 456, in feed_data
    assert not self._eof, 'feed_data after feed_eof'
AssertionError: feed_data after feed_eof
10:04:16.001 | ERROR   | asyncio - Exception in callback SubprocessStreamProtocol.pipe_data_received(2, 
bytearray(b'10:04:16.000 | '))
handle: <Handle SubprocessStreamProtocol.pipe_data_received(2, bytearray(b'10:04:16.000 | '))>
Traceback (most recent call last):
  File "C:\Users\Tim\anaconda3\lib\asyncio\events.py", line 80, in _run
    self._context.run(self._callback, *self._args)
  File "C:\Users\Tim\anaconda3\lib\asyncio\subprocess.py", line 72, in pipe_data_received
    reader.feed_data(data)
  File "C:\Users\Tim\anaconda3\lib\asyncio\streams.py", line 456, in feed_data
    assert not self._eof, 'feed_data after feed_eof'
AssertionError: feed_data after feed_eof
10:04:16.003 | ERROR   | asyncio - Exception in callback SubprocessStreamProtocol.pipe_data_received(2, 
bytearray(b"I...pleted()\r\n"))
handle: <Handle SubprocessStreamProtocol.pipe_data_received(2, bytearray(b"I...pleted()\r\n"))>
Traceback (most recent call last):
  File "C:\Users\Tim\anaconda3\lib\asyncio\events.py", line 80, in _run
    self._context.run(self._callback, *self._args)
  File "C:\Users\Tim\anaconda3\lib\asyncio\subprocess.py", line 72, in pipe_data_received
    reader.feed_data(data)
  File "C:\Users\Tim\anaconda3\lib\asyncio\streams.py", line 456, in feed_data
    assert not self._eof, 'feed_data after feed_eof'
AssertionError: feed_data after feed_eof
10:04:16.279 | ERROR   | prefect.flow_runs.worker - An error occurred while monitoring flow run '796a4690-ad27-45a4-ae61-45d405e760f9'. The flow run will not be marked as failed, but an issue may have occurred.
Traceback (most recent call last):
  File "C:\Users\Tim\anaconda3\lib\site-packages\prefect\workers\base.py", line 800, in _submit_run_and_capture_errors
    result = await self.run(
  File "C:\Users\Tim\anaconda3\lib\site-packages\prefect\workers\process.py", line 177, in run
    process = await run_process(
  File "C:\Users\Tim\anaconda3\lib\site-packages\prefect\utilities\processutils.py", line 273, in run_process
    await consume_process_output(
  File "C:\Users\Tim\anaconda3\lib\site-packages\prefect\utilities\processutils.py", line 287, in consume_process_output
    async with anyio.create_task_group() as tg:
  File "C:\Users\Tim\anaconda3\lib\site-packages\anyio\_backends\_asyncio.py", line 597, in __aexit__   
    raise exceptions[0]
  File "C:\Users\Tim\anaconda3\lib\site-packages\prefect\utilities\processutils.py", line 305, in stream_text
    async for item in source:
  File "C:\Users\Tim\anaconda3\lib\site-packages\anyio\abc\_streams.py", line 34, in __anext__
    return await self.receive()
  File "C:\Users\Tim\anaconda3\lib\site-packages\anyio\streams\text.py", line 46, in receive
    decoded = self._decoder.decode(chunk)
  File "C:\Users\Tim\anaconda3\lib\codecs.py", line 322, in decode
    (result, consumed) = self._buffer_decode(data, self.errors, final)
UnicodeDecodeError: 'utf-8' codec can't decode byte 0xb3 in position 101: invalid start byte

PYTHONUTF8=1