We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c00a9d5 commit 9cca017Copy full SHA for 9cca017
src/sch/eager.jl
@@ -23,7 +23,11 @@ function init_eager()
23
return
24
end
25
ctx = eager_context()
26
- errormonitor_tracked("eager compute()", Threads.@spawn try
+ # N.B. We use @async here to prevent the scheduler task from running on a
27
+ # different thread than the one that is likely submitting work, as otherwise
28
+ # the scheduler task might sleep while holding the scheduler lock and
29
+ # prevent work submission until it wakes up. Further testing is needed.
30
+ errormonitor_tracked("eager compute()", @async try
31
sopts = SchedulerOptions(;allow_errors=true)
32
opts = Dagger.Options((;scope=Dagger.ExactScope(Dagger.ThreadProc(1, 1)),
33
occupancy=Dict(Dagger.ThreadProc=>0),
0 commit comments