Skip to content

Commit b813f6c

Browse files
committed
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 79b4ca8d7b498a728912bf9d66d31890ff0f8667) (cherry picked from commit d65a9960ae358806312c1adf35f45c62f02caf0b)
1 parent bd251bb commit b813f6c

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
@@ -614,7 +614,7 @@ function launch_n_additional_processes(manager, frompid, fromconfig, cnt, launch
614614
end
615615
end
616616

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

0 commit comments

Comments
 (0)