gracefull shutdown if python interpreter dies: #131

LUCIT-Systems-and-Development · Nov 25, 2020 · e3582fa · e3582fa
1 parent f43dd29
commit e3582fa
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/unicorn_binance_websocket_api/unicorn_binance_websocket_api_manager.py b/unicorn_binance_websocket_api/unicorn_binance_websocket_api_manager.py
@@ -414,6 +414,11 @@ def _create_stream_thread(self,
         try:
             loop.run_until_complete(socket.start_socket())
         except RuntimeError as error_msg:
+            if "cannot schedule new futures after interpreter shutdown" in error_msg:
+                logging.critical(f"BinanceWebSocketApiManager._create_stream_thread() stream_id={str(stream_id)} "
+                                 f" - RuntimeError error_msg:  - {str(error_msg)} - stopping and shutting down ...")
+                self.stop_manager_with_all_streams()
+                sys.exit(1)
             logging.critical(f"BinanceWebSocketApiManager._create_stream_thread() stream_id={str(stream_id)} "
                              f"error: 7 - {str(error_msg)} - if this stream did not restart after this error, please "
                              f"create an issue: "