Skip to content

Commit 0aab968

Browse files
committed
Fix a JET error by narrowing the type signature of the create_worker(x, y) function
``` ┌ 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}) └──────────────────── ```
1 parent df4b9ec commit 0aab968

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
@@ -605,7 +605,7 @@ function launch_n_additional_processes(manager, frompid, fromconfig, cnt, launch
605605
end
606606
end
607607

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

0 commit comments

Comments
 (0)