file formatting

BulkBeing · BulkBeing · commit f9402cafe7dd · 2026-03-12T00:48:04.000Z
Branch-Creation-Time: 2026-03-12T00:42:31+0000
diff --git a/packages/pynumaflow/pynumaflow/reducestreamer/async_server.py b/packages/pynumaflow/pynumaflow/reducestreamer/async_server.py
@@ -171,6 +171,7 @@ def start(self):
         _LOGGER.info(
             "Starting Async Reduce Stream Server",
         )
+
         def _shutdown_handler(loop):
             _LOGGER.info("Received graceful shutdown signal, shutting down ReduceStream server")
             if self.shutdown_callback:

Original file line number	Diff line number	Diff line change
`@@ -171,6 +171,7 @@ def start(self):`
`171`	`171`	`_LOGGER.info(`
`172`	`172`	`"Starting Async Reduce Stream Server",`
`173`	`173`	`)`
	`174`	`+`
`174`	`175`	`def _shutdown_handler(loop):`
`175`	`176`	`_LOGGER.info("Received graceful shutdown signal, shutting down ReduceStream server")`
`176`	`177`	`if self.shutdown_callback:`