v0.12.0
What's Changed
- feat(streamsorter): flush on timeout, adjust logging by @th0ger in #279
- fix: add idleness to stream-sorter example by @vigith in #280
- feat: metadata implementation for source, map and sink by @BulkBeing in #274
- chore: update accumulator example with initSourceDelay. by @vaibhavtiwari33 in #287
- fix(example): update cron schedule format by @vigith in #295
- feat(example): side-input manifests by @vigith in #297
- Fix Python 3.14 compatibility issue with uvloop dependency by @BulkBeing in #300
- feat: Support for on_success sink in pynumaflow by @vaibhavtiwari33 in #302
- fix: Sourcer - Change pending/partitions handlers of Source to async by @BulkBeing in #301
- chore: Fix reduce streaming counter example by @vaibhavtiwari33 in #307
- feat: add metadata support for source transformer by @cosmic-chichu in #312
- v0.12.0 release by @BulkBeing in #313
New Contributors
- @vaibhavtiwari33 made their first contribution in #287
Full Changelog: v0.11.0...v0.12.0