Remove signal handling in examples

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

Author: BulkBeing

packages/pynumaflow-lite/manifests/accumulator/accumulator_stream_sorter.py

@@ -130,14 +130,5 @@ async def main():
             pass
         return
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
 if __name__ == "__main__":
     asyncio.run(main())

packages/pynumaflow-lite/manifests/batchmap/batchmap_cat.py

@@ -22,15 +22,6 @@ async def handler(
             responses.append(resp)
         return responses
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start(
     f: Callable[
         [AsyncIterable[batchmapper.Datum]], Awaitable[batchmapper.BatchResponses]

packages/pynumaflow-lite/manifests/map/map_cat.py

@@ -17,15 +17,6 @@ async def handler(self, keys: list[str], payload: mapper.Datum) -> mapper.Messag
 
         return messages
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start(f: Callable[[list[str], mapper.Datum], Awaitable[mapper.Messages]]):
     server = mapper.MapAsyncServer()
 

packages/pynumaflow-lite/manifests/mapstream/mapstream_cat.py

@@ -18,15 +18,6 @@ async def handler(
         for s in parts:
             yield Message(s.encode(), keys)
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start(f: Callable[[list[str], mapstreamer.Datum], AsyncIterator[Message]]):
     # Use default socket/info file locations; no explicit sock file passed
     server = mapstreamer.MapStreamAsyncServer()

packages/pynumaflow-lite/manifests/reduce/reduce_counter_class.py

@@ -26,15 +26,6 @@ async def handler(
         out.append(reducer.Message(msg, keys))
         return out
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start(creator: type[reducer.Reducer], init_args: tuple):
     sock_file = "/var/run/numaflow/reduce.sock"
     server_info_file = "/var/run/numaflow/reducer-server-info"

packages/pynumaflow-lite/manifests/reducestream/reducestream_counter.py

@@ -70,15 +70,6 @@ async def handler(
         print(f"Yielding final result: counter={self.counter}")
         yield reducestreamer.Message(msg, keys=keys)
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start(creator: type, init_args: tuple):
     """Start the reduce stream server."""
     sock_file = "/var/run/numaflow/reducestream.sock"

packages/pynumaflow-lite/manifests/session_reduce/session_reduce_counter_class.py

@@ -78,13 +78,5 @@ async def main():
             pass
         return
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
 if __name__ == "__main__":
     asyncio.run(main())

packages/pynumaflow-lite/manifests/sideinput/sideinput_example.py

@@ -85,15 +85,6 @@ def update_data_from_file(self, path):
         except Exception as e:
             print(f"Error reading file: {e}")
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start_sideinput():
     """Start the SideInput retriever server."""
     server = sideinputer.SideInputAsyncServer()

packages/pynumaflow-lite/manifests/sink/sink_log.py

@@ -26,15 +26,6 @@ async def handler(self, datums: AsyncIterable[sinker.Datum]) -> sinker.Responses
             # we can use Response.as_fallback(msg.id) to write the message to fallback sink
         return responses
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start(
     f: Callable[[AsyncIterator[sinker.Datum]], Awaitable[sinker.Responses]],
 ):

packages/pynumaflow-lite/manifests/source/simple_source.py

@@ -92,15 +92,6 @@ async def partitions_handler(self) -> sourcer.PartitionsResponse:
         """
         return sourcer.PartitionsResponse(partitions=[self.partition_idx])
 
-
-# Optional: ensure default signal handlers are in place so asyncio.run can handle them cleanly.
-signal.signal(signal.SIGINT, signal.default_int_handler)
-try:
-    signal.signal(signal.SIGTERM, signal.SIG_DFL)
-except AttributeError:
-    pass
-
-
 async def start():
     server = sourcer.SourceAsyncServer()