v0.4.2

What's Changed

• fix: update event time filter transformer to use tag by @KeranYang in #92
• chore: use ruff for linting; add precommit conf by @ab93 in #94
• feat: introduce MapStreamFn for streaming map udf in async sever by @xdevxy in #93
• feat!: support len, iter and indexing on udf datatypes by @ab93 in #96
• chore: improve udsink dtypes by @ab93 in #97
• chore: add map stream udf example by @xdevxy in #95
• chore: bump version to '0.4.2' by @xdevxy in #98

Full Changelog: v0.4.1...v0.4.2

v0.4.1

What's Changed

• docs: updated CHANGELOG.md by @github-actions in #86
• chore: graceful grpc error handling by @ashwinidulams in #88
• feat: introduce handshake to client and gRPC server by @kohlisid in #89
• chore: bump version to 0.4.1 by @ab93 in #90

Full Changelog: v0.4.0...v0.4.1

v0.4.0

What's Changed

• docs: updated CHANGELOG.md by @github-actions in #51
• chore: update protobuf version by @sandangel in #56
• chore: allow protobuf 3.20 and above by @ab93 in #62
• docs: examples for asyncio with ThreadPoolExecutor and ProcessPoolExecutor by @kohlisid in #61
• feat: bidirectional streaming for reduce by @yhl25 in #55
• feat: add mapt sdk support by @KeranYang in #64
• chore: add named parameters to UDF call by @kohlisid in #65
• refactor: make default constructor private for Message/MessageT by @KeranYang in #67
• fix: store strong references of task objects by @kohlisid in #66
• fix: stream to stdout stderr based on log level by @sandangel in #69
• chore: re-raise UDFError instead of dropping messages by @KeranYang in #71
• feat: support for multi keys by @yhl25 in #72
• chore: convert keys to list by @yhl25 in #74
• feat: add multiprocessing support for Map by @kohlisid in #73
• fix: doc typo fix by @vigith in #75
• feat: Add ID and numDelivered fields to Datum in udf by @xdevxy in #77
• feat: introducing tags for conditional forwarding by @yhl25 in #76
• doc: explain how to use datum metadata. by @xdevxy in #78
• chore: fix MessageT constructor by @yhl25 in #83
• chore: refactor into server classes by @kohlisid in #81
• chore!: remove support for py3.8; add 3.11 by @ab93 in #85

New Contributors

• @sandangel made their first contribution in #56
• @yhl25 made their first contribution in #55
• @KeranYang made their first contribution in #64
• @xdevxy made their first contribution in #77

Full Changelog: v0.3.3...v0.4.0

v0.3.3

What's Changed

• docs: updated CHANGELOG.md by @github-actions in #45
• chore: update example pynumaflow version by @chromevoid in #46
• perf: improve performance by adding slots by @ab93 in #47
• feat: reduce stream per window using asyncio by @ashwinidulams in #49
• chore: aiorun to manage lifecycle of ayncio processes by @ashwinidulams in #50

New Contributors

• @ashwinidulams made their first contribution in #49

Full Changelog: v0.3.2...v0.3.3

v0.3.2

What's Changed

• docs: updated CHANGELOG.md by @github-actions in #42
• fix: time unit bug/dockerfile/add a guide by @chromevoid in #44

Full Changelog: v0.3.1...v0.3.2

v0.3.1

What's Changed

• chore: update examples by @chromevoid in #39
• feat: udf reduce by @chromevoid in #40
• chore: bump version to v0.3.1 by @ab93 in #41
• docs: updated CHANGELOG.md by @github-actions in #38

Full Changelog: v0.3.0...v0.3.1

v0.3.0

Note: Breaking change! Will only work with numaflow v0.7.0 onwards

What's Changed

• docs: updated CHANGELOG.md by @github-actions in #29
• docs: update udf and udsink links in README.md by @dseapy in #30
• chore: update the pynumaflow version in the examples. by @vigith in #33
• fix: .flake8 file by @ab93 in #35
• feat: udsink gRPC stream by @chromevoid in #34
• chore: bump version to v0.3 by @ab93 in #37

New Contributors

• @dseapy made their first contribution in #30

Full Changelog: v0.2.6...v0.3.0

v0.2.6

What's Changed

• docs: updated CHANGELOG.md by @github-actions in #22
• feat: add support to configure max message size by @chromevoid in #23
• feat: introduces sync gRPC server by @ab93 in #27
• chore: bump version to v0.2.6 by @ab93 in #28

New Contributors

• @github-actions made their first contribution in #22

Full Changelog: v0.2.5...v0.2.6

v0.2.5

What's Changed

• chore: bump version to 0.2.4 by @ab93 in #13
• chore: flatmap and simple udsink examples push to quay by @whynowy in #15
• chore: remove unwanted dependencies by @ab93 in #17
• chore: add auto changelog generation by @ab93 in #19
• fix: catch exception in udf and udsink by @ab93 in #18
• chore: bump version to v0.2.5 by @ab93 in #21

New Contributors

• @whynowy made their first contribution in #15

Full Changelog: v0.2.4...v0.2.5

v0.2.4

What's Changed

• update function socket by @cosmic-chichu in #12

New Contributors

• @cosmic-chichu made their first contribution in #12

Full Changelog: v0.2.3...v0.2.4