Carlos Cueto
01/19/2023, 3:56 PMprefect-dask
and my flows that use prefect-shell
's shell_run_command
started failing with the following error:
Encountered exception during execution:
Traceback (most recent call last):
File "C:\scripts\prefect2\lib\site-packages\prefect\engine.py", line 1478, in orchestrate_task_run
result = await task.fn(*args, **kwargs)
File "C:\scripts\prefect2\lib\site-packages\prefect_shell\commands.py", line 86, in shell_run_command
async with await open_process(
File "C:\scripts\prefect2\lib\site-packages\anyio\_core\_subprocesses.py", line 127, in open_process
return await get_asynclib().open_process(
File "C:\scripts\prefect2\lib\site-packages\anyio\_backends\_asyncio.py", line 1105, in open_process
process = await asyncio.create_subprocess_exec(
File "C:\python310\lib\asyncio\subprocess.py", line 218, in create_subprocess_exec
transport, protocol = await loop.subprocess_exec(
File "C:\python310\lib\asyncio\base_events.py", line 1675, in subprocess_exec
transport = await self._make_subprocess_transport(
File "C:\python310\lib\asyncio\base_events.py", line 498, in _make_subprocess_transport
raise NotImplementedError
NotImplementedError
Whenever I do uninstall prefect-dask via pip uninstall prefect-dask
, everything goes back to working smoothly. This seems related to asyncio based on the error. Anyone has any clues as to why this might be happening?Zanie
01/19/2023, 4:39 PMCarlos Cueto
01/19/2023, 6:50 PMZanie
01/19/2023, 6:53 PMCarlos Cueto
01/19/2023, 7:02 PMZanie
01/19/2023, 7:04 PM