mschubert / clustermq

R package to send function calls as jobs on LSF, SGE, Slurm, PBS/Torque, or each via SSH
https://mschubert.github.io/clustermq/
Apache License 2.0
145 stars 26 forks source link

recv() hangs on Mac OS #321

Closed wlandau closed 7 months ago

wlandau commented 7 months ago

I am using clustermq 0.9.1, and recv() hangs indefinitely on Mac OS.

options(clustermq.scheduler = "multicore")
library(clustermq)
workers <- workers(n_jobs = 1L, log_worker = TRUE)
workers$recv()

The worker launches quickly, and after about a minute of hanging the log still reads:

2023-12-04 14:36:47.217572 | Master: tcp://<HOSTNAME>:6453
2023-12-04 14:36:47.222991 | connecting to: tcp://<HOSTNAME>:6453

Session info:

R version 4.3.2 (2023-10-31)
Platform: aarch64-apple-darwin20 (64-bit)
Running under: macOS Sonoma 14.1.2

Matrix products: default
BLAS:   /Library/Frameworks/R.framework/Versions/4.3-arm64/Resources/lib/libRblas.0.dylib 
LAPACK: /Library/Frameworks/R.framework/Versions/4.3-arm64/Resources/lib/libRlapack.dylib;  LAPACK version 3.11.0

locale:
[1] en_US.UTF-8/en_US.UTF-8/en_US.UTF-8/C/en_US.UTF-8/en_US.UTF-8

time zone: America/Indiana/Indianapolis
tzcode source: internal

attached base packages:
[1] stats     graphics  grDevices utils     datasets  methods   base     

other attached packages:
[1] clustermq_0.9.1

loaded via a namespace (and not attached):
[1] compiler_4.3.2   R6_2.5.1         parallel_4.3.2   Rcpp_1.0.11     
[5] codetools_0.2-19
mschubert commented 7 months ago

Can you try the current git? (specifically https://github.com/mschubert/clustermq/commit/db38d683567d51b31dcc55c6324d30ccd286fd69)

wlandau commented 7 months ago

It works now, thanks!

mschubert commented 7 months ago

This is on CRAN now