Skip to content

Commit 856d4b7

Browse files
committed
Initialize worker connections eagerly
This may help with connection errors in CI.
1 parent ff01cd4 commit 856d4b7

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

Diff for: test/fault-tolerance.jl

+4-4
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
d = delayed(kill_func)(b, c)
3636
@test collect(d) == 6
3737

38-
addprocs(2)
38+
addprocs(2; lazy=false)
3939
using Dagger
4040
setup_funcs(workers() |> last)
4141

@@ -44,7 +44,7 @@
4444
c = delayed(kill_func)(a, b)
4545
@test collect(c) == 6
4646

47-
addprocs(2)
47+
addprocs(2; lazy=false)
4848
using Dagger
4949
setup_funcs(workers() |> last)
5050

@@ -56,7 +56,7 @@
5656
c = delayed(kill_func)(b1, b2)
5757
@test collect(c) == 8
5858

59-
addprocs(2)
59+
addprocs(2; lazy=false)
6060
using Dagger
6161
setup_funcs(workers() |> last)
6262

@@ -66,7 +66,7 @@
6666
d = delayed(kill_func)(b, c)
6767
@test_throws AssertionError collect(d; options=Dagger.Sch.SchedulerOptions(single=first(workers())))
6868

69-
addprocs(1)
69+
addprocs(1; lazy=false)
7070
using Dagger
7171
setup_funcs(workers() |> last)
7272
end

Diff for: test/runtests.jl

+1-1
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ end
7171

7272

7373
using Distributed
74-
addprocs(3)
74+
addprocs(3; lazy=false)
7575

7676
include("imports.jl")
7777
include("util.jl")

Diff for: test/scheduler.jl

+1-1
Original file line numberDiff line numberDiff line change
@@ -202,7 +202,7 @@ end
202202
main_scope = Dagger.scope(worker=myid())
203203
@test fetch(Dagger.@spawn scope=main_scope myid()) == myid()
204204

205-
ps2 = addprocs(1, exeflags="--project")
205+
ps2 = addprocs(1, exeflags="--project"; lazy=false)
206206
append!(ps, ps2)
207207
@everywhere ps2 $setup
208208

Diff for: test/scopes.jl

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
@testset "Chunk Scopes" begin
2-
wid1, wid2 = addprocs(2, exeflags=["-t 2"])
2+
wid1, wid2 = addprocs(2, exeflags=["-t 2"]; lazy=false)
33
@everywhere [wid1,wid2] using Dagger
44
Dagger.addprocs!([wid1,wid2])
55
fetch(Dagger.@spawn 1+1) # Force scheduler to pick up new workers

0 commit comments

Comments
 (0)