Skip to content

Commit

Permalink
ci may need more time (macOS on GHA really slow)
Browse files Browse the repository at this point in the history
  • Loading branch information
mschubert committed Oct 19, 2023
1 parent 5be0d01 commit 3dfd951
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions tests/testthat/test-2-worker.r
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,7 @@ test_that("worker R API", {
# addr = m$listen("inproc://endpoint") # mailbox.cpp assertion error

p = parallel::mcparallel(worker(addr))
expect_null(m$recv(500L))
expect_null(m$recv(1000L))
m$send(expression(5 + 1))
res = m$recv(500L)
expect_equal(res[[1]], 6)
Expand All @@ -139,7 +139,7 @@ test_that("communication with two workers", {
w1 = parallel::mcparallel(worker(addr))
w2 = parallel::mcparallel(worker(addr))

expect_null(m$recv(500L)) # worker 1 up
expect_null(m$recv(1000L)) # worker 1 up
m$send(expression({ Sys.sleep(0.5); 5 + 2 }))
expect_null(m$recv(500L)) # worker 2 up
m$send(expression({ Sys.sleep(0.5); 3 + 1 }))
Expand Down
8 changes: 4 additions & 4 deletions tests/testthat/test-7-ssh_proxy.r
Original file line number Diff line number Diff line change
Expand Up @@ -59,8 +59,8 @@ test_that("using the proxy without pool and forward", {
addr = m$listen("tcp://127.0.0.1:*")
p = parallel::mcparallel(ssh_proxy(sub(".*:", "", addr)))

m$proxy_submit_cmd(list(n_jobs=1), 500L)
expect_null(m$recv(500L)) # worker 1 up
m$proxy_submit_cmd(list(n_jobs=1), 1000L)
expect_null(m$recv(1000L)) # worker 1 up
m$send(5 + 2)
expect_equal(m$recv(500L), 7) # collect results

Expand All @@ -81,8 +81,8 @@ test_that("using the proxy without pool and forward, 2 workers", {
addr = m$listen("tcp://127.0.0.1:*")
p = parallel::mcparallel(ssh_proxy(sub(".*:", "", addr)))

m$proxy_submit_cmd(list(n_jobs=2), 500L)
expect_null(m$recv(500L)) # worker 1 up
m$proxy_submit_cmd(list(n_jobs=2), 1000L)
expect_null(m$recv(1000L)) # worker 1 up
m$send({ Sys.sleep(0.5); 5 + 2 })
expect_null(m$recv(500L)) # worker 2 up
m$send({ Sys.sleep(0.5); 3 + 1 })
Expand Down

0 comments on commit 3dfd951

Please sign in to comment.