Use a timer for periodic functions

servicelayer/taskqueue.py

@@ -395,9 +395,11 @@ def __init__(
         self.version = version
         self.prefetch_count = prefetch_count
         self.local_queue = Queue()
+        self.periodic_timer = threading.Timer(interval=30, function=self.periodic)
 
     def on_signal(self, signal, _):
         log.warning(f"Shutting down worker (signal {signal})")
+        self.periodic_timer.cancel()
         # Exit eagerly without waiting for current task to finish running
         sys.exit(int(signal))
 
@@ -413,6 +415,8 @@ def on_message(self, channel, method, properties, body, args):
 
     def process_blocking(self):
         """Blocking worker thread - executes tasks from a queue and periodic tasks"""
+        self.periodic_timer.start()
+        log.info("Starting periodic timer")
         while True:
             try:
                 (task, channel, connection) = self.local_queue.get(timeout=TIMEOUT)
@@ -424,7 +428,7 @@ def process_blocking(self):
                 pass
             finally:
                 clear_contextvars()
-                self.periodic()
+                self.periodic_timer.cancel()
 
     def process_nonblocking(self):
         """Non-blocking worker is used for tests only."""