From c263772703936ee9bc8f864eb927f0325c3599b1 Mon Sep 17 00:00:00 2001 From: Jake Moshenko Date: Mon, 5 Dec 2016 18:11:21 -0500 Subject: [PATCH] Do not extend processing immediately after taking queue item. --- workers/security_notification_worker.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/workers/security_notification_worker.py b/workers/security_notification_worker.py index a33bc9762..91f482aec 100644 --- a/workers/security_notification_worker.py +++ b/workers/security_notification_worker.py @@ -12,7 +12,6 @@ from util.secscan.notifier import process_notification_data logger = logging.getLogger(__name__) -_READING_SECONDS = 120 # 2 minutes _PROCESSING_SECONDS = 60 * 60 # 1 hour _LAYER_LIMIT = 1000 # The number of layers to request on each page. @@ -31,7 +30,6 @@ class SecurityNotificationWorker(QueueWorker): current_page = data.get('page', None) while True: - self.extend_processing(_READING_SECONDS, json.dumps(data)) (response_data, should_retry) = secscan_api.get_notification(notification_name, layer_limit=_LAYER_LIMIT, page=current_page)