Skip to content

Commit 2aeea50

Browse files
committed
Rename one method of run_work_thunk() to run_work_thunk_remotevalue(); this fixes a JET error around matching methods for run_work_thunk(...) (#181)
This fixes the following JET error: ``` │┌ run_work_thunk(rv::Distributed.RemoteValue, thunk::Bool) @ Distributed /workpath/Distributed.jl/src/process_messages.jl:79 ││ no matching method found `run_work_thunk(::Bool, ::Bool)`: Distributed.run_work_thunk(thunk::Bool, false) │└──────────────────── ``` (cherry picked from commit 2adcd26e81cec03dbf81fa94071b4c4499e539a1)
1 parent 21a0e25 commit 2aeea50

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/process_messages.jl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ function run_work_thunk(thunk::Function, print_error::Bool)
7575
end
7676
return result
7777
end
78-
function run_work_thunk(rv::RemoteValue, thunk)
78+
function run_work_thunk_remotevalue(rv::RemoteValue, thunk)
7979
put!(rv, run_work_thunk(thunk, false))
8080
nothing
8181
end
@@ -85,7 +85,7 @@ function schedule_call(rid, thunk)
8585
rv = RemoteValue(def_rv_channel())
8686
(PGRP::ProcessGroup).refs[rid] = rv
8787
push!(rv.clientset, rid.whence)
88-
errormonitor(@async run_work_thunk(rv, thunk))
88+
errormonitor(@async run_work_thunk_remotevalue(rv, thunk))
8989
return rv
9090
end
9191
end

0 commit comments

Comments
 (0)