fix cold shutdown

kuyruk/master.py

@@ -134,12 +134,12 @@ def cold_shutdown(self):
         logger.warning("Cold shutdown")
         self.shutdown_pending.set()
         self.shutdown_workers(kill=True)
-        sys.exit(0)
+        os._exit(0)
 
     def abort(self):
         """Exit immediately making workers orphan."""
         logger.warning("Aborting")
-        sys.exit(0)
+        os._exit(0)
 
     def get_stats(self):
         """Generate stats to be sent to manager."""
@@ -190,8 +190,6 @@ def run_worker(self):
         logger.debug("Running worker command")
         run_worker(self.kuyruk, args)
 
-        sys.exit(0)
-
     def close_fds(self):
         logger.debug("Closing open file descriptors...")
         maxfd = resource.getrlimit(resource.RLIMIT_NOFILE)[1]

kuyruk/process.py

@@ -72,7 +72,7 @@ def warm_shutdown(self):
 
     def cold_shutdown(self):
         logger.warning("Cold shutdown")
-        sys.exit(0)
+        os._exit(0)
 
     def maybe_start_manager_thread(self, socket_lock=None):
         if self.config.MANAGER_HOST:

kuyruk/worker.py

@@ -329,7 +329,7 @@ def handle_sigquit(self, signum, frame):
                 logger.critical("Cannot send ACK for the current task.")
                 traceback.print_exc()
         logger.warning("Exiting...")
-        sys.exit(0)
+        os._exit(0)
 
     def quit_task(self):
         self.handle_sigquit(None, None)