feat: Update Sourcer interface for propagating totalPartitions by vaibhavtiwari33 · Pull Request #343 · numaproj/numaflow-python

feat: Sourcer changes: * deprecate partitions_handler, * Add support for active_partitions_handler and total_partitions, * Maintain backward compatibility

vaibhavtiwari33

committed

chore: fix linting

vaibhavtiwari33

committed

chore: Update example to use active_partitions_handler

vaibhavtiwari33

committed

chore: Revert grpcio version to 1.75.0. Regenerate proto files with this version

vaibhavtiwari33

committed

chore: remove the unused total_partitions from PartitionsResponse class in sourcer/_dtypes

vaibhavtiwari33

committed

chore: fix init method for PartitionsResponse

vaibhavtiwari33

committed

break backward compatibility to force implementing active_partitions

vaibhavtiwari33

committed

chore: fix linting

vaibhavtiwari33

committed

chore: [pynumaflow-lite] lint and clippy checks in makefile (#344)

vaibhavtiwari33

committed

chore: update active partitions handler doc comment

vaibhavtiwari33

committed

chore: fix SyncSourceError test class to implement active_partitions_handler

vaibhavtiwari33

committed

Update packages/pynumaflow/pynumaflow/sourcer/_dtypes.py

vaibhavtiwari33

and

vigith

committed

Merge branch 'main' into total_partitions

vaibhavtiwari33

authored

chore: fix linting

vaibhavtiwari33

committed

chore: fix linting

vaibhavtiwari33

committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: Update Sourcer interface for propagating totalPartitions#343

feat: Update Sourcer interface for propagating totalPartitions#343
vigith merged 15 commits intomainfrom
total_partitions

Commits on Mar 28, 2026

feat: Sourcer changes: * deprecate partitions_handler, * Add support for active_partitions_handler and total_partitions, * Maintain backward compatibility

chore: fix linting

chore: Update example to use active_partitions_handler

chore: Revert grpcio version to 1.75.0. Regenerate proto files with this version

chore: remove the unused total_partitions from PartitionsResponse class in sourcer/_dtypes

chore: fix init method for PartitionsResponse

break backward compatibility to force implementing active_partitions

chore: fix linting

chore: [pynumaflow-lite] lint and clippy checks in makefile (#344)

chore: update active partitions handler doc comment

chore: fix SyncSourceError test class to implement active_partitions_handler

Update packages/pynumaflow/pynumaflow/sourcer/_dtypes.py

Merge branch 'main' into total_partitions

chore: fix linting

chore: fix linting