Skip to content

Commit 2dd02dc

Browse files
Update packages/pynumaflow/pynumaflow/sourcer/_dtypes.py
Co-authored-by: Vigith Maurice <vigith@gmail.com>
1 parent 53b9855 commit 2dd02dc

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

packages/pynumaflow/pynumaflow/sourcer/_dtypes.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ async def active_partitions_handler(self) -> PartitionsResponse:
306306

307307
async def total_partitions_handler(self) -> int | None:
308308
"""
309-
Optional. Returns the total number of partitions in the source.
309+
Returns the total number of partitions in the source.
310310
Used by the platform for watermark progression to know when all
311311
processors have reported in.
312312
Returns None by default, indicating the source does not report total partitions.

0 commit comments

Comments
 (0)