diff --git a/utils/queues.py b/utils/queues.py index 173b017..10278b5 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -17,10 +17,11 @@ class QueuesException(Exception): class TasksHandlerMixin: def poll(self): while True: - response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}) - print('Got status', response.status_code) - print('Got body', response.content.decode('utf-8')) - response = response.json() + try: + response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}).json() + except requests.JSONDecodeError: + print('Unable to decode json') + continue task = response.get('task') if not task: time.sleep(0.2)