[core][aDAG] asyncio.queue raises an exception at python 3.9

ray-project / ray

Ray is a unified framework for scaling AI and Python applications. Ray consists of a core distributed runtime and a set of AI Libraries for accelerating ML workloads.

https://ray.io

Apache License 2.0

33.31k stars 5.64k forks source link

[core][aDAG] asyncio.queue raises an exception at python 3.9 #47869

Open rkooo567 opened 5 days ago

rkooo567 commented 5 days ago

What happened + What you expected to happen

https://github.com/ray-project/ray/blob/c8aa7f1f6b1fa9efa6dc149bd00698a50900af75/python/ray/dag/compiled_dag_node.py#L592

This code seems to raise an exception because it cannot find the asyncio loop when it is not used with asyncio when python 3.9 is used

Versions / Dependencies

n/a

Reproduction script

n/a

Issue Severity

None

Superskyyy commented 2 days ago

I can't seem to reproduce this on my 3.9 environment?