TQR Watchdog: Added to control and TD.

CESNET · Jun 28, 2024 · 2d387cf · 2d387cf
1 parent 6c72abc
commit 2d387cf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/dp3/task_processing/task_distributor.py b/dp3/task_processing/task_distributor.py
@@ -74,6 +74,8 @@ def __init__(
             worker_index=self.process_index,
             rabbit_config=self.rabbit_params,
         )
+        registrar.scheduler_register(self._task_queue_reader.watchdog, second="20,50")
+
         # Writer - allows modules to write new tasks
         self._task_queue_writer = TaskQueueWriter(
             platform_config.app_name, self.num_processes, self.rabbit_params

diff --git a/dp3/worker.py b/dp3/worker.py
@@ -224,6 +224,7 @@ def sigint_handler(signum, frame):
         ControlAction.refresh_module_config,
         partial(reload_module_config, log, platform_config, modules),
     )
+    global_scheduler.register(control.control_queue.watchdog, second="15,45")
 
     ##############################################
     # Load all plug-in modules