fixup! debug

JuliaParallel · Nov 14, 2024 · 880eebe · 880eebe
1 parent 5fb2ef9
commit 880eebe
Show file tree

Hide file tree

Showing 3 changed files with 1,913 additions and 1,909 deletions.
diff --git a/src/process_messages.jl b/src/process_messages.jl
@@ -307,7 +307,11 @@ function handle_msg(msg::CallWaitMsg, header, r_stream, w_stream, version)
 end
 
 function handle_msg(msg::RemoteDoMsg, header, r_stream, w_stream, version)
-    errormonitor(@async run_work_thunk(()->invokelatest(msg.f, msg.args...; msg.kwargs...), true))
+    errormonitor(@async try
+                     run_work_thunk(()->invokelatest(msg.f, msg.args...; msg.kwargs...), true)
+                 catch ex
+                     @error "Caught exception" exception=ex
+                 end)
 end
 
 function handle_msg(msg::ResultMsg, header, r_stream, w_stream, version)