Changes¶

v2.1.0 (2019-08-29)¶

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