Changes

v1.0.0

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

v0.1.3

  • Added support for joblib>=0.10

v0.1.2

  • 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.

v0.1.1

  • pescador.mux now throws a RuntimeError exception if the seed pool is empty

v0.1.0

Initial public release