Skip to content

Commit a362506

Browse files
committed
submission: Reset sch_accessible for dependencies
1 parent 4ec9a35 commit a362506

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/submission.jl

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -199,6 +199,15 @@ const UID_TO_TID_CACHE = TaskLocalValue{ReusableCache{Dict{UInt64,Int},Nothing}}
199199
id_map[uid] = thunk.id
200200
end
201201

202+
# Reset sch_accessible for all syncdeps
203+
if options.syncdeps !== nothing
204+
for dep_weak in options.syncdeps
205+
dep = unwrap_weak_checked(dep_weak)
206+
@assert dep.eager_accessible "GC bug: lost eager reference to syncdep"
207+
dep.sch_accessible = true
208+
end
209+
end
210+
202211
# Tell the scheduler that it has new tasks to schedule
203212
if reschedule
204213
put!(state.chan, Sch.RescheduleSignal())

0 commit comments

Comments
 (0)