Sfoglia il codice sorgente

celerybeat: Reset SIGTERM signal if running as embedded process

Ask Solem 15 anni fa
parent
commit
8da2a0c0d9
1 ha cambiato i file con 1 aggiunte e 0 eliminazioni
  1. 1 0
      celery/beat.py

+ 1 - 0
celery/beat.py

@@ -259,6 +259,7 @@ def EmbeddedClockService(*args, **kwargs):
             self.clockservice = ClockService(*args, **kwargs)
             self.clockservice = ClockService(*args, **kwargs)
 
 
         def run(self):
         def run(self):
+            platform.reset_signal("SIGTERM")
             self.clockservice.start(embedded_process=True)
             self.clockservice.start(embedded_process=True)
 
 
         def stop(self):
         def stop(self):