- 255d20b fix: add the error to the global result queue (#315)
- 7a26f15 feat: support shutdown_callback argument in XXXAsyncServer (#311)
- Kazuki Yamamoto
- Vigith Maurice
- 298a7f1 v0.12.0 release (#313)
- 14e369a feat: add metadata support for source transformer (#312)
- 27ad810 fix(typing): pyi, examples, and manifest (#309)
- 17b2c22 feat: metadata propagation (system/user) in pynumaflow-lite (#305)
- 9b043d4 fix: Sourcer - Change pending/partitions handlers of Source to async (#301)
- eae7222 feat: API documentation site using Github pages (#303)
- 2ebe47f feat: Support for on_success sink in pynumaflow (#302)
- 5500636 Fix Python 3.14 compatibility issue with uvloop dependency (#300)
- 5dacaa7 feat(example): side-input manifests (#297)
- 9311f25 feat: side-input for pynumaflow-lite (#296)
- 02e5145 fix(example): update cron schedule format (#295)
- 24ce158 feat: source-transformer for pynumaflow-lite (#293)
- 62f698b feat(examples): reduce streaming example (#291)
- 0e2bafe feat: Reduce streaming for pynumaflow_lite (#290)
- ee2351d fix(doc): point examples to new location (#288)
- c9dccff doc: update README for clarity and corrections (#284)
- de595ad feat: source using rust sdk (#283)
- d9c9192 feat: sink integration for pynumaflow-lite (#281)
- c3c3f19 feat: metadata implementation for source, map and sink (#274)
- 83eeb23 fix: add idleness to stream-sorter example (#280)
- fe0bd4e feat(streamsorter): flush on timeout, adjust logging (#279)
- Martin Thøgersen
- Sreekanth
- Vaibhav Kant Tiwari
- Vigith Maurice
- shrivardhan
- 96f966e v0.11.0 release (#275)
- 792abc5 feat: Rust SDK based implementation of - accumulator, batchmap, map, mapstream, reduce, session_reduce (#273)
- 5571d8c doc: README for numaflow-python project (#259)
- 5f2c89a feat: Nack support for Sources (#252)
- c7ca40a fix: Function call syntax error (#251)
- Sreekanth
- Vigith Maurice
- bf00b2e feat: parallelized mapstreamer (#242)
- b944a5d doc: fix async reducer README examples (#244)
- 4982414 feat: add Accumulator (#237)
- Martin Thøgersen
- Sidhant Kohli
- shrivardhan
- Sidhant Kohli
- shrivardhan
- 6ccd49e feat: utility function to persist critical error (#222)
- Adarsh Jain
- f2f7bf6 feat: update batchmap and mapstream to use Map proto (#200)
- 4788627 feat: bi-directional streaming map (#197)
- a1d3eb5 feat: streaming transformer (#196)
- ec00728 feat: streaming sink (#193)
- b1b2d94 fix: update side-input readme (#194)
- 7180ce2 feat: container-type level version compatibility check (#190)
- Keran Yang
- Sidhant Kohli
- 921b7c0 feat: batch-map implementation (#177)
- 61195e5 fix: modify Dockerfiles to fix failing image builds (#180)
- Abdullah Yildirim
- Sidhant Kohli
- 225e8b0 fix: udf type in multiproc source transformer (#171)
- Sidhant Kohli
- 06a6fdc feat: UDF container should crash on exceptions (#160)
- Sidhant Kohli
- 0c2501b feat: add fallback sink support (#157)
- af095a1 fix: convert headers to dict before exposing to users (#151)
- Sidhant Kohli
- Yashash H L
- 06a6fdc feat: UDF container should crash on exceptions (#160)
- 0c2501b feat: add fallback sink support (#157)
- af095a1 fix: convert headers to dict before exposing to users (#151)
- 5d99fb8 feat: support headers for message (#138)
- 04914fa fix: readme (#143)
- b366e2f feat: implement reduce streaming (#134)
- c3f9c60 feat: implement update script #102 (#137)
- df6afe6 feat: add support for new reduce proto (#133)
- 39ec103 feat: class based refactor for SDK (#129)
- Abdullah Yildirim
- Sidhant Kohli
- Vigith Maurice
- Yashash H L
- e6e1261 feat: adding partitions for user defined source (#124)
- 3e3b25f fix: require event time when dropping messages (#123)
- Keran Yang
- Sidhant Kohli
- Aaron Tolman
- Sidhant Kohli
- 71c2b52 feat: Add User Defined Source support (#114)
- Sidhant Kohli
- c04a279 fix: multiproc mapper max threads and default numprocess (#112)
- Avik Basu
- c5a4695 feat: add side input grpc service (#107)
- Sidhant Kohli
- 0be0b48 Update flatmap stream sdk version dependency (#99)
- xdevxy
- 15a6723 feat!: support len, iter and indexing on udf datatypes (#96)
- c441ebe feat: introduce
MapStreamFnfor streaming map udf in async sever (#93) - 97d7f4e fix: update event time filter transformer to use tag (#92)
- Avik Basu
- Keran Yang
- xdevxy
- ee753f5 feat: introduce handshake to client and gRPC server (#89)
- Sidhant Kohli
- 58ff85c chore!: remove support for py3.8; add 3.11 (#85)
- 405c5cd doc: explain how to use datum metadata. (#78)
- d252283 feat: introducing tags for conditional forwarding (#76)
- 786b48e feat: Add ID and numDelivered fields to Datum in udf (#77)
- 1849f10 fix: doc typo fix (#75)
- d142648 feat: add multiprocessing support for Map (#73)
- acba109 feat: support for multi keys (#72)
- 6fa43d6 fix: stream to stdout stderr based on log level (#69)
- f6c914e fix: store strong references of task objects (#66)
- 3e81304 refactor: make default constructor private for Message/MessageT (#67)
- cd8eac2 feat: add mapt sdk support (#64)
- ea78057 feat: bidirectional streaming for reduce (#55)
- Avik Basu
- Keran Yang
- San Nguyen
- Sidhant Kohli
- Vigith Maurice
- Yashash H L
- xdevxy
- f13bc5f feat: reduce stream per window using asyncio (#49)
- df9c8c8 perf: improve performance by adding slots (#47)
- Avik Basu
- ashwinidulams
- a650aac fix: time unit bug/dockerfile/add a guide (#44)
- Juanlu Yu
- d33ddd0 feat: udf reduce (#40)
- Juanlu Yu
- Avik Basu
- Juanlu Yu
- 0fbecc1 feat: introduces sync gRPC server (#27)
- b6a4bc0 feat: add support to configure max message size (#23)
- Avik Basu
- Juanlu Yu
- 97b410e fix: catch exception in udf and udsink (#18)
- Avik Basu
- 3559e15 update function socket (#12)
- shrivardhan
- dd861c0 doc: update UDSink (#10)
- Vigith Maurice
- fd88178 fix: unix domain socket path and examples (#6)
- Juanlu Yu
- 043e109 feat: udsink gRPC (#5)
- Juanlu Yu
- 496543c feature: gRPC (#4)
- Chrome