code formatting

Signed-off-by: Sreekanth <prsreekanth920@gmail.com>

Author: BulkBeing

packages/pynumaflow/pynumaflow/accumulator/servicer/task_manager.py

@@ -13,7 +13,8 @@
     Datum,
     _AccumulatorBuilderClass,
     AccumulatorAsyncCallable,
-    WindowOperation, AccumulatorRequest,
+    WindowOperation,
+    AccumulatorRequest,
 )
 from pynumaflow.proto.accumulator import accumulator_pb2
 from pynumaflow.shared.asynciter import NonBlockingIterator
@@ -219,9 +220,7 @@ async def __invoke_accumulator(
             # Put the exception in the result queue
             await self.global_result_queue.put(err)
 
-    async def process_input_stream(
-        self, request_iterator: AsyncIterable[AccumulatorRequest]
-    ):
+    async def process_input_stream(self, request_iterator: AsyncIterable[AccumulatorRequest]):
         # Start iterating through the request iterator and create tasks
         # based on the operation type received.
         try: