Commits

Branch selector

 master

User selector

All users

All time

Commit History

Commits on Apr 7, 2026

• Release 0.6.6

  martindurant

  committed
  ff215fb

  Copy full SHA for ff215fb

Commits on Feb 24, 2026

• Merge pull request #498 from dwskoog/update_dockerfile

  Show description for 30c1666
  martindurant

  authored
  30c1666

  Copy full SHA for 30c1666

Commits on Feb 22, 2026

• Refresh the Dockerfile

  Show description for afc891c
  dwskoog

  committed
  afc891c

  Copy full SHA for afc891c

• Get the image tag from the package version

  dwskoog

  committed
  bb6382e

  Copy full SHA for bb6382e

• Updated Kafka no longer uses Zookeeper

  dwskoog

  committed
  cc317b6

  Copy full SHA for cc317b6

Commits on Feb 5, 2026

• Merge pull request #497 from dwskoog/update_contrib

  Show description for 969f3ad
  martindurant

  authored
  969f3ad

  Copy full SHA for 969f3ad

• Refresh CONTRIBUTING.md

  dwskoog

  committed
  ab8cacd

  Copy full SHA for ab8cacd

• Update setup.py to require Python>=3.10

  dwskoog

  committed
  ca5fb2b

  Copy full SHA for ca5fb2b

• Cleanup flake8 warnings outside of streamz module

  dwskoog

  committed
  221bf7b

  Copy full SHA for 221bf7b

Commits on Jan 26, 2026

• Merge pull request #496 from a-detiste/master

  Show description for 4f0a7d3
  martindurant

  authored
  4f0a7d3

  Copy full SHA for 4f0a7d3

Commits on Jan 25, 2026

• setuptools is not needed at runtime, only at build-time

  a-detiste

  committed
  2657091

  Copy full SHA for 2657091

Commits on Jan 21, 2026

• Merge pull request #494 from dwskoog/example_fixes

  Show description for ffbd59d
  martindurant

  authored
  ffbd59d

  Copy full SHA for ffbd59d

• Merge pull request #495 from dwskoog/map_async_improvements

  Show description for 3c0f570
  martindurant

  authored
  3c0f570

  Copy full SHA for 3c0f570

Commits on Jan 20, 2026

• Drop Python 3.9 support

  dwskoog

  committed
  3203a73

  Copy full SHA for 3203a73

Commits on Jan 16, 2026

• Show off restarting map_async when it stops

  dwskoog

  committed
  9a7b3ed

  Copy full SHA for 9a7b3ed

• Make map_async restartable

  dwskoog

  committed
  96463b5

  Copy full SHA for 96463b5

• from_iterable was over-consuming during stop

  dwskoog

  committed
  c357729

  Copy full SHA for c357729

• Rework map_async to handle failures better

  Show description for 09969c5
  dwskoog

  committed
  09969c5

  Copy full SHA for 09969c5

• Merge pull request #493 from dwskoog/map_async

  Show description for 3e0beab
  martindurant

  authored
  3e0beab

  Copy full SHA for 3e0beab

Commits on Jan 9, 2026

• Use Stream.connect to loop the fib examples

  dwskoog

  committed
  5ad905e

  Copy full SHA for 5ad905e

• Ensure flatten.update([]) does not kill the stream

  Show description for 2eba95a
  dwskoog

  committed
  2eba95a

  Copy full SHA for 2eba95a

• Attempt to bind free port in word count test

  dwskoog

  committed
  e4d708c

  Copy full SHA for e4d708c

• Refresh URL scraper example

  Show description for 860ec25
  dwskoog

  committed
  860ec25

  Copy full SHA for 860ec25

• Refresh the Fibonnaci examples

  Show description for f1b6660
  dwskoog

  committed
  f1b6660

  Copy full SHA for f1b6660

• Source.from_tcp fixes

  Show description for 3f6135c
  dwskoog

  committed
  3f6135c

  Copy full SHA for 3f6135c

Commits on Dec 23, 2025

• Allow for map_async to run items in parallel

  Show description for ea57a59
  dwskoog

  committed
  ea57a59

  Copy full SHA for ea57a59

• Take a hint from buffer about backpressure

  dwskoog

  committed
  34509c7

  Copy full SHA for 34509c7

• Fix the callback shutting itself off

  Show description for 2506a92
  dwskoog

  committed
  2506a92

  Copy full SHA for 2506a92

• Mark the dataframe GC test as flaky

  dwskoog

  committed
  39bcbd8

  Copy full SHA for 39bcbd8

• Use await_for idiom to make tests declarative

  dwskoog

  committed
  5c24950

  Copy full SHA for 5c24950

• Add documentation on map_async

  dwskoog

  committed
  aa122bd

  Copy full SHA for aa122bd

• Add map_async to api.rst

  dwskoog

  committed
  1683bfc

  Copy full SHA for 1683bfc

• Create new map_async api

  Show description for 02c5e25
  dwskoog

  committed
  02c5e25

  Copy full SHA for 02c5e25

Commits on Dec 18, 2025

• release

  martindurant

  committed
  8c73290

  Copy full SHA for 8c73290

• Merge pull request #492 from dwskoog/python_312_event_loop_warnings

  Show description for 3677648
  martindurant

  authored
  3677648

  Copy full SHA for 3677648