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()
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
Issue Severity
None