From 90c3723189e2561a2d85382591944002326ddfb7 Mon Sep 17 00:00:00 2001 From: Sidhant Kohli Date: Thu, 7 Mar 2024 16:47:48 -0800 Subject: [PATCH] comments Signed-off-by: Sidhant Kohli --- pynumaflow/reducestreamer/servicer/async_servicer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pynumaflow/reducestreamer/servicer/async_servicer.py b/pynumaflow/reducestreamer/servicer/async_servicer.py index b7477b16..c577fcdd 100644 --- a/pynumaflow/reducestreamer/servicer/async_servicer.py +++ b/pynumaflow/reducestreamer/servicer/async_servicer.py @@ -103,7 +103,7 @@ async def ReduceFn( # Any exceptions that occur during the processing reduce function tasks are # sent to the result queue. We then forward these exception to the client # - # 3. A reduce_pb2.Window message + # 3. A reduce_pb2.ReduceResponse message with EOF=True # This is a special message that indicates the end of the processing for a window # When we get this message, we send an EOF message to the client try: