Set healthcheck time at start of each process

cuda-networks · Aug 20, 2020 · 2dcce5a · 2dcce5a
1 parent 838d348
commit 2dcce5a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/eb_sqs/worker/service.py b/eb_sqs/worker/service.py
@@ -29,6 +29,8 @@ class WorkerService(object):
 
     def process_queues(self, queue_names):
         # type: (list) -> None
+        self.write_healthcheck_file()
+
         logger.debug('[django-eb-sqs] Connecting to SQS: {}'.format(', '.join(queue_names)))
 
         sqs = boto3.resource(
@@ -73,11 +75,9 @@ def process_queues(self, queue_names):
                 self.process_messages(queues, worker, static_queues)
 
     def process_messages(self, queues, worker, static_queues):
-
-        self.write_healthcheck_file()
+        # type: (list, Worker, list) -> None
         last_healthcheck_time = timezone.now()
 
-        # type: (list, Worker, list) -> None
         for queue in queues:
             try:
                 messages = self.poll_messages(queue)