Recent Releases of clustermq
clustermq - clustermq 0.9.9
- The Windows binary no longer includes the disconnect monitor
- Fix more CRAN warnings and test timeouts
- R
Published by mschubert 10 months ago
clustermq - clustermq 0.9.8
- Suppress R6 clonable message
- Fix CRAN warning about
cppzmqdeprecated declaration
- R
Published by mschubert 12 months ago
clustermq - clustermq 0.9.7
- Fix a bug where
BiocGenericscould break template filling (#337) - Remove deprecated automatic array splitting in
Q
- R
Published by mschubert about 1 year ago
clustermq - clustermq 0.9.6
- Large common data size is now reported correctly (#336)
- Template filling will no longer convert large numbers to scientific format
- Common data will no longer be duplicated when sending to workers
- R
Published by mschubert about 1 year ago
clustermq - clustermq 0.9.5
- Fix a bug where an outdated system
libzmqled to compilation errors (#327) - New option
clustermq.portsspecifies eligible port range (#328) @michaelmayer2
- R
Published by mschubert over 1 year ago
clustermq - clustermq 0.9.4
- Fix a bug where worker stats were shown as
NA(#325) @luwidmer - Worker API:
env()now visibly lists environment if called without arguments
- R
Published by mschubert almost 2 years ago
clustermq - clustermq 0.9.3
- Fix a bug where
BiocParalleldid not export required objects (#302) @bhayete-empress - Fix a bug where already finished workers were killed (#307) @luwidmer
- Fix a bug where worker results and stats could be garbage collected (#324) @kkman
- There is now an FAQ vignette with answers to frequently asked questions
- Worker API:
send()now reports a call identifier thatcurrent()tracks
- R
Published by mschubert about 2 years ago
clustermq - clustermq 0.9.2
- Fix a bug where SSH proxy would not cache data properly (#320)
- Fix a bug where
max_calls_workerwas not respected (#322) - Local parallelism (
multicore,multiprocess) again uses local IP (#321) - Worker API:
info()now also returns current worker and number of calls
- R
Published by mschubert about 2 years ago
clustermq - clustermq 0.9.1
- Disconnect monitor (libzmq with
-DZMQ_BUILD_DRAFT_API=1) is now optional (#317) - Fix a bug where worker shutdown notifications can cause a crash (#306, #308, #310)
- Fix a bug where template values were not filled correctly (#309)
- Fix a bug where using
Rf_errorlead to improper cleanup of resources (#311) - Fix a bug where maximum worker timeout was multiplied and led to undefined behavior
- Fix a bug where ZeroMQ's
-Werrorflag led to compilation issues on M1 Mac - Fix a bug where SSH tests could error with timeout on high load
- Worker API:
CMQMasternow needs to knowadd_pending_workers(n) - Worker API: status report
info()now displays properly
- R
Published by mschubert over 2 years ago
clustermq - clustermq 0.9.0
Features
- Reuse of common data is now supported (#154)
- Jobs now error instead of stalling upon unexpected worker disconnect (#150)
- Workers now error if they can not establish a connection within a time limit
- Error if
n_jobsandmax_calls_workerprovide insufficient call slots (#258) - Request 1 GB by default in SGE template (#298) @nickholway
- Error and warning summary now orders by index and severity (#304)
- A call can have multiple warnings forwarded, not only last
Bugfix
- Fix bug where max memory reporting by
gc()may be in different column (#240) - Fix passing numerical
job_idtoqdelin PBS (#265) - The job port/id pool is now used properly upon binding failure (#270) @luwidmer
- Common data size warning is now only displayed when exceeding limits (#287)
Under the hood
- Complete rewrite of the worker API
- We no longer depend on the
purrrpackage
- R
Published by mschubert over 2 years ago
clustermq - clustermq 0.8.95
- We are now using ZeroMQ via
Rcppin preparation forv0.9(#151) - New
multiprocessbackend viacallrinstead of forking (#142, #197) - Sending data on sockets is now blocking to avoid excess memory usage (#161)
multicore,multiprocessschedulers now support logging (#169)- New option
clustermq.hostcan specify host IP or network interface name (#170) - Template filling will now raise error for missing keys (#174, #198)
- Workers failing with large common data is improved (fixed?) (#146, #179, #191)
- Local connections are now routed via
127.0.0.1instead oflocalhost(#192) - Submit messages are different between local, multicore and HPC (#196)
- Functions exported by
foreachnow have their environment stripped (#200) - Deprecation of
log_worker=T/Fargument is rescinded
- R
Published by mschubert over 5 years ago
clustermq - clustermq 0.8.9
- New option
clustermq.ssh.timeoutfor SSH proxy startup (#157) @brendanf - New option
clustermq.worker.timeoutfor delay before worker shutdown (#188) - Fixed PBS/Torque docs, template and cleanup (#184, #186) @mstr3336
- Warning if common data is very large, set by
clustermq.data.warning(#189)
- R
Published by mschubert almost 6 years ago
clustermq - clustermq 0.8.8
Q,Q_rowshave new argumentsverbose(#111) andpkgs(#144)foreachbackend now uses its dedicated API where possible (#143, #144)- Number and size of objects common to all calls now work properly
- Templates are filled internally and no longer depend on
infuserpackage
- R
Published by mschubert over 6 years ago
clustermq - clustermq 0.8.7
Qnow hasmax_calls_workerargument to avoid walltime (#110)- Submission messages now list size of common data (drake#800)
- All default templates now have an optional
coresper job field (#123) foreachnow treats.export(#124) and.combine(#126) correctly- New option
clustermq.error.timeoutto not wait for clean shutdown (#134) - SSH command is now specified via a template file (#122)
- SSH will now forward errors to the local process (#135)
- The Wiki is deprecated, use https://mschubert.github.io/clustermq/ instead
- R
Published by mschubert almost 7 years ago
clustermq - clustermq 0.8.6
- Progress bar is now shown before any workers start (#107)
- Socket connections are now authenticated using a session password (#125)
- Marked internal functions with
@keywords internal - Added vignettes for the User Guide and Technical Documentation
- R
Published by mschubert almost 7 years ago
clustermq - clustermq 0.8.5
- Added experimental support for parallel
foreachbackend (#83) - Moved templates to package
inst/directory (#85) - Added
send_callto worker to evaluate arbitrary expressions (drake#501; #86) - Option
clustermq.scheduleris now respected if set after package load (#88) - System interrupts are now handled correctly (rzmq#44; #73, #93, #97)
- Number of workers running/total is now shown in progress bar (#98)
- Unqualified (short) host names are now resolved by default (#104)
- R
Published by mschubert over 7 years ago
clustermq - clustermq 0.8.4
- Fix error for
qsys$reusablewhen usingn_jobs=0/local processing (#75) - Scheduler-specific templates are deprecated. Use
clustermq.templateinstead - Allow option
clustermq.defaultsto fill default template values (#71) - Errors in worker processing are now shut down cleanly (#67)
- Progress bar now shows estimated time remaining (#66)
- Progress bar now also shown when processing locally
- Memory summary now adds estimated memory of R session (#69)
- R
Published by mschubert almost 8 years ago
clustermq - clustermq 0.8.3
- Support
rettypefor function calls where return type is known (#59) - Reduce memory requirements by processing results when we receive them
- Fix a bug where cleanup,
log_workerflag were not working for SGE/SLURM
- R
Published by mschubert about 8 years ago
clustermq - clustermq 0.8.2
- Fix a bug where never-started jobs are not cleaned up
- Fix a bug where tests leave processes if port binding fails (#60)
- Multicore no longer prints worker debug messages (#61)
- R
Published by mschubert about 8 years ago
clustermq - clustermq 0.8.1
- Fix performance issues for a high number of function calls (#56)
- Fix bug where multicore workers were not shut down properly (#58)
- Fix default templates for SGE, LSF and SLURM (misplaced quote)
- R
Published by mschubert over 8 years ago
clustermq - clustermq 0.6.2
Provides the Q function to seamlessly evaluate function calls in an HPC scheduling environment
- R
Published by mschubert over 8 years ago
clustermq - clustermq 0.8.0
API changes
- Templates changed:
clustermq:::workernow takes only master as argument - Jobs will now be submitted as array if possible
New functionality
- Creating
workersis now separated fromQ, enabling worker reuse (#45) - Added
multicoreqsys using theparallelpackage (#49) - New function
Q_rowsusing data.frame rows as iterated arguments (#43) - Messages on the master are now processed in threads (#42)
- Job summary will now report max memory as reported by
gc(#18)
Bugfix
- Fix a bug where copies of
common_dataare collected by gc too slowly (#19) - Objects in the function environment must now be
exported explicitly (#47)
- R
Published by mschubert over 8 years ago
clustermq - clustermq 0.7.0
Initial release on CRAN
https://cran.r-project.org/web/packages/clustermq/index.html
- R
Published by mschubert over 8 years ago