From f27122ce567d884dd85e8dd8f28b2b17adc36adc Mon Sep 17 00:00:00 2001 From: Egor Matveev Date: Sat, 28 Dec 2024 14:18:34 +0300 Subject: [PATCH] fix --- utils/queues.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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)