diff --git a/dp3/task_processing/task_distributor.py b/dp3/task_processing/task_distributor.py
index 64f6cb27..79465ab9 100644
--- 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
index 850d42d6..9087d606 100755
--- 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