Changes¶

v3.0.0 (2024-03-12)¶

#171 New distribution modes for StochasticMux: constant and binomial (new default). The rate parameter in poisson mode (old default) now has slightly reduced variance compared to pescador 2.x.
#170 Replaced JSON encoding for data headers with msgpack in ZMQStreamer.
#168 Improved exception tracing for maps.
#159, #164, #166, #167 Modernized packaging and updated to support Python up to 3.12. Removed support for python 2.
#162 Corrected documentation for streamer

#156 Added support for python 3.7
#153 Added the cache map
#151 Added the decorator interface for defining streamers
#150 Streamer objects now directly support iterator inputs
#150 Removed deprecated Mux class, which has been replaced by StochastixMux.

This release is the second major revision of the pescador architecture, and includes many substantial changes to the API.

This release contains no changes from the release candidate 2.0.0rc0.

#103 Deprecation and refactor of the Mux class. Its functionality has been superseded by new classes StochasticMux, ShuffledMux, ChainMux, and RoundRobinMux.
#109 Removed deprecated features from the 1.x series: - BufferedStreamer class - Streamer.tuples method
#111 Removed the internally-facing StreamActivator class
#113 Bugfix: multiply-activated streamers (and muxes) no longer share state
#116 Streamer.cycle now respects the max_iter parameter
#121 Added minimum dependency version requirements
#106 Added more advanced examples in the documentation

This is primarily a maintenance release, and will be the last in the 1.x series.

This release constitutes a major revision over the 0.x series, and the new interface is not backward-compatible.

#23 Preserve memory alignment of numpy arrays across ZMQ streams
#34 Rewrite of all core functionality under a unified object interface Streamer.
#35, #52 Removed the StreamLearner interface and scikit-learn dependency
#44 Added a base exception class PescadorError
#45 Removed the util submodule
#47, #60 Improvements to documentation
#48 Fixed a timeout bug in ZMQ streamer
#53 Added testing and support for python 3.6
#57 Added the tuple() interface for Streamers
#61 Improved test coverage
#63 Added random state to Mux
#64 Added __call__ interface to Streamer

Added pescador.mux parameter revive. Calling with with_replacement=False, revive=True will use each seed at most once at any given time.
Added pescador.zmq_stream parameter timeout. Setting this to a positive number will terminate dangling worker threads after timeout is exceeded on join. See also: multiprocessing.Process.join.

Initial public release