Skip to content

Commit d65a996

Browse files
authored
Fix a JET error by narrowing the type signature of the create_worker(x, y) function (#175)
``` ┌ create_worker(manager::Any, wconfig::Any) @ Distributed /workpath/Distributed.jl/src/cluster.jl:620 │ no matching method found `kwcall(::NamedTuple{(:config,), <:Tuple{Any}}, ::Type{Distributed.Worker}, ::Any, ::Sockets.TCPSocket, ::Sockets.TCPSocket, ::Base.LibuvStream)` (1/2 union split): Core.kwcall(NamedTuple{(:config,)}(tuple(wconfig::Any)::Tuple{Any})::NamedTuple{(:config,), <:Tuple{Any}}, Distributed.Worker, (getfield(w::Core.Box, :contents)::Any).id::Any, r_s::Sockets.TCPSocket, w_s::Sockets.TCPSocket, manager::Union{Base.LibuvStream, Distributed.ClusterManager}) └──────────────────── ``` (cherry picked from commit 79b4ca8)
1 parent 3ebddd3 commit d65a996

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/cluster.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -608,7 +608,7 @@ function launch_n_additional_processes(manager, frompid, fromconfig, cnt, launch
608608
end
609609
end
610610

611-
function create_worker(manager, wconfig)
611+
function create_worker(manager::ClusterManager, wconfig::WorkerConfig)
612612
# only node 1 can add new nodes, since nobody else has the full list of address:port
613613
@assert LPROC.id == 1
614614
timeout = worker_timeout()

0 commit comments

Comments
 (0)