We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e8ea59e commit 691e109Copy full SHA for 691e109
eb_sqs/worker/service.py
@@ -69,10 +69,7 @@ def process_queues(self, queue_names):
69
logger.info('[django-eb-sqs] DEFAULT_MAX_RETRIES = {}'.format(settings.DEFAULT_MAX_RETRIES))
70
logger.info('[django-eb-sqs] REFRESH_PREFIX_QUEUES_S = {}'.format(settings.REFRESH_PREFIX_QUEUES_S))
71
72
- while True:
73
- if self._exit_gracefully:
74
- break
75
-
+ while not self._exit_gracefully:
76
if len(queue_prefixes) > 0 and \
77
timezone.now() - timedelta(seconds=settings.REFRESH_PREFIX_QUEUES_S) > last_update_time:
78
queues = static_queues + self.get_queues_by_prefixes(sqs, queue_prefixes)
0 commit comments