v0.13.0

What's Changed

• fix: increase minimum protobuf version to 6.31.1 by @khneal in #318
• chore: Drop Python 3.9 support by @BulkBeing in #322
• fix: Clean shutdown for Sink Async server using asyncio.Event by @BulkBeing in #323
• fix: Clean shutdown for Sink threaded server using threading.Event by @BulkBeing in #325
• fix: use keyed_window.keys for task lookup in accumulator task manager by @BulkBeing in #330
• fix: Handle window closes correctly in reducestreamer by @BulkBeing in #331
• fix: Validate message fields before protobuf encoding for better error messages by @BulkBeing in #333
• fix: Graceful shutdown for all UDFs by @BulkBeing in #337
• chore: remove unused SyncSource classes by @vaibhavtiwari33 in #345
• feat: Update Sourcer interface for propagating totalPartitions by @vaibhavtiwari33 in #343
• fix: Avoid UDF call in map streaming from starving eventloop by @BulkBeing in #349
• fix: Avoid event loop starvation if user has tight loops in streaming UDFs by @BulkBeing in #352

Sourcer Interface Changes

The pynumaflow.sourcer.Sourcer abstract class has been updated.

Removed:

• partitions_handler

Added:

• active_partitions_handler
• total_partitions_handler

Full Changelog: v0.12.1...v0.13.0