test

Author: aaugustin

app.py

@@ -193,7 +193,16 @@ async def main():
     # Set the stop condition when receiving SIGTERM.
     loop = asyncio.get_running_loop()
     stop = loop.create_future()
-    loop.add_signal_handler(signal.SIGTERM, stop.set_result, None)
+
+    def sig_handler():
+        print(stop._state)
+        try:
+            stop.set_result(None)
+        except Exception as exc:
+            print(exc)
+
+
+    loop.add_signal_handler(signal.SIGTERM, sig_handler)
 
     port = int(os.environ.get("PORT", "8001"))
     async with serve(handler, "", port, process_request=health_check):