Support SIGHUP for immediate run

src/app.py

@@ -74,6 +74,8 @@ def exit_app():
     signal.signal(signal.SIGINT, lambda *x: exit_app())
     signal.signal(signal.SIGTERM, lambda *x: exit_app())
 
+    signal.signal(signal.SIGHUP, scheduler.run_now)
+
 
 def setup_metrics():
     metrics_port = read_configuration('METRICS_PORT', default_config_path)

src/scheduler/__init__.py

@@ -6,6 +6,10 @@ class Scheduler(object):
     def schedule(self, func, *args, **kwargs):
         raise NotImplementedError('%s.schedule not implemented' % type(self).__name__)
 
+    @abc.abstractmethod
+    def run_now(self):
+        raise NotImplementedError('%s.run_now not implemented' % type(self).__name__)
+
     @abc.abstractmethod
     def cancel(self):
         raise NotImplementedError('%s.cancel not implemented' % type(self).__name__)

src/scheduler/oneshot.py

@@ -5,5 +5,8 @@ class OneShotScheduler(Scheduler):
     def schedule(self, func, *args, **kwargs):
         func(*args, **kwargs)
 
+    def run_now(self):
+        pass
+
     def cancel(self):
         exit(1)

src/scheduler/repeat.py

@@ -32,6 +32,9 @@ def schedule(self, func, *args, **kwargs):
                     self.timer = threading.Timer(self.interval, self._run)
                     self.timer.start()
 
+    def run_now(self):
+        self._run()
+
     def _run(self):
         with self.lock:
             if self.cancelled:

tests/test_repeat_scheduler.py

@@ -90,3 +90,15 @@ def test_repeats(self):
         self.scheduler.cancel()
 
         self.assertAlmostEqual(self.invocations, 5, delta=1)
+
+    def test_run_now(self):
+        self.scheduler = MockScheduler()
+        self.scheduler.time = 60
+
+        self.scheduler.schedule(self._invoke)
+
+        self.assertEqual(self.invocations, 0)
+
+        self.scheduler.run_now()
+
+        self.assertEqual(self.invocations, 1)