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