Skip to content

Commit 79b4ca8

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 61ff327 commit 79b4ca8

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
@@ -598,7 +598,7 @@ function launch_n_additional_processes(manager, frompid, fromconfig, cnt, launch
598598
end
599599
end
600600

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

0 commit comments

Comments
 (0)