diff --git a/utils/queues.py b/utils/queues.py index dec794a..07f3c29 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -18,7 +18,7 @@ class QueuesException(Exception): class TasksHandlerMixin: def poll(self): while True: - response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}) + response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json() task = response.get('task') if not task: time.sleep(0.2)