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

Co-authored-by: Vigith Maurice <vigith@gmail.com>
Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>

Author: vaibhavtiwari33

packages/pynumaflow/pynumaflow/sourcer/_dtypes.py

@@ -306,7 +306,7 @@ async def active_partitions_handler(self) -> PartitionsResponse:
 
     async def total_partitions_handler(self) -> int | None:
         """
-        Optional. Returns the total number of partitions in the source.
+        Returns the total number of partitions in the source.
         Used by the platform for watermark progression to know when all
         processors have reported in.
         Returns None by default, indicating the source does not report total partitions.