Skip to content

Releases: xpdAcq/streamz_ext

0.2.1

07 Aug 21:07

Choose a tag to compare

Added:

  • Tools for linking pipeline chunks together
  • zip and zip_latest take in first kwarg so that those nodes can
    be run first (rewriting the execution graph order)

0.2.0

10 Jun 23:40

Choose a tag to compare

Added:

  • first kwarg to combine_latest allowing users to re-order the pipeline
    as needed when using combine_latest. This helps with jug handle like
    graphs where a source node is both part of both the incoming streams, by
    allowing the emit_on stream(s) to be computed later, permitting the
    buffers to be filled when emit_on emits.
  • Test for unique using lists

0.1.0

01 Jun 06:03

Choose a tag to compare

Added:

  • orch build system

Changed:

  • unique now handles all non hashables in a deque rather than just
    dicts
  • Pull tests from streamz

Removed:

  • Most of the defined nodes, as streamz has caught up to us.

0.0.2

17 Jan 18:59

Choose a tag to compare

Added:

  • Args and kwargs to the filter node

  • Imports from all the streamz tests for more coverage

  • Conda-forge activity to rever

0.0.1

11 Jan 19:07

Choose a tag to compare

Added:

  • Add rever
  • Initialize project for extending mrocklin/streamz