ray icon indicating copy to clipboard operation
ray copied to clipboard

[aDAG][Core] Weird exception if ref is deleted after adag teardown

Open rkooo567 opened this issue 5 months ago • 2 comments

What happened + What you expected to happen

We call ray.get on ref del, but if the dag is already teardown, it raises an weird exception

Versions / Dependencies

master

Reproduction script

import ray
from ray.dag import InputNode, MultiOutputNode

ray.init()

@ray.remote
class A:
    def f(self, inp):
        return 1

a = A.remote()
b = A.remote()
with InputNode() as inp:
    x = b.f.bind(inp)
    y = a.f.bind(inp)
    dag = MultiOutputNode([x,y ])
adag = dag.experimental_compile()
refs = adag.execute(1)
adag.teardown()

Issue Severity

None

rkooo567 avatar Sep 16 '24 16:09 rkooo567