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 047347a commit b0cfba7Copy full SHA for b0cfba7
src/sch/util.jl
@@ -26,6 +26,7 @@ function errormonitor_tracked_set!(name::String, t::Task)
26
return
27
end
28
29
+ error("Task not found in tracked list")
30
31
32
const ERRORMONITOR_TRACKED = LockedObject(Pair{String,Task}[])
src/utils/reuse.jl
@@ -545,7 +545,11 @@ function (cache::ReusableTaskCache)(f, name::String)
545
Sch.errormonitor_tracked_set!(name, cache.tasks[idx])
546
return cache.tasks[idx]
547
else
548
- t = Task(()->f)
+ t = @task try
549
+ @invokelatest f()
550
+ catch err
551
+ @error "[$r] Error in non-reusable task" exception=(err, catch_backtrace())
552
+ end
553
cache.setup_f(t)
554
schedule(t)
555
Sch.errormonitor_tracked(name, t)
0 commit comments