diff --git a/src/sch/eager.jl b/src/sch/eager.jl index 260eb7ad9..b90646c27 100644 --- 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