diff --git a/config.py b/config.py index 3b9eebfc8..f6c15a2d6 100644 --- a/config.py +++ b/config.py @@ -105,6 +105,7 @@ class DefaultConfig(object): # Build Queue Metrics QUEUE_METRICS_TYPE = 'Null' + QUEUE_WORKER_METRICS_REFRESH_SECONDS = 300 # Exception logging EXCEPTION_LOG_TYPE = 'FakeSentry' diff --git a/workers/queueworker.py b/workers/queueworker.py index cdd96d9e7..8b76a5a90 100644 --- a/workers/queueworker.py +++ b/workers/queueworker.py @@ -40,7 +40,8 @@ class QueueWorker(Worker): # Add the various operations. self.add_operation(self.poll_queue, self._poll_period_seconds) - self.add_operation(self.update_queue_metrics, 60) + self.add_operation(self.update_queue_metrics, + app.config['QUEUE_WORKER_METRICS_REFRESH_SECONDS']) self.add_operation(self.run_watchdog, self._watchdog_period_seconds) def process_queue_item(self, job_details):