Reference Dagger.EAGER_THUNK_STREAMS explicitly

JuliaParallel · May 23, 2024 · 5fb2b3c · 5fb2b3c
1 parent c9c60f4
commit 5fb2b3c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/sch/eager.jl b/src/sch/eager.jl
@@ -117,7 +117,7 @@ function eager_cleanup(state, uid)
         delete!(state.thunk_dict, tid)
     end
     remotecall_wait(1, uid) do uid
-        lock(EAGER_THUNK_STREAMS) do global_streams
+        lock(Dagger.EAGER_THUNK_STREAMS) do global_streams
             if haskey(global_streams, uid)
                 delete!(global_streams, uid)
             end