I only recently installed

prefect-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?

Ooo

Glad I could help! I did spend quite a long time creating recreating virtual environments and installing libraries one by one. Through trial and error I narrowed it down to that one.

If you’re feeling particularly ambitious, it’d be great to have confirmation that the reproduction I posted there fails and the traceback for it.

Done

Thanks!