diff --git a/utils/queues.py b/utils/queues.py index 10278b5..dc0f219 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -21,6 +21,7 @@ class TasksHandlerMixin: response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json() except requests.JSONDecodeError: print('Unable to decode json') + time.sleep(3) continue task = response.get('task') if not task: