From e6e3762768d09517fc7a38de826dbbc0196a4390 Mon Sep 17 00:00:00 2001 From: emmatveev Date: Wed, 27 Nov 2024 02:17:26 +0300 Subject: [PATCH] fix --- utils/queues.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/utils/queues.py b/utils/queues.py index 923bc3b..dec794a 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -19,10 +19,11 @@ class TasksHandlerMixin: def poll(self): while True: response = requests.get(f'{QUEUES_URL}/api/v1/take', headers={'queue': self.queue_name}) - if response.status_code == 404: + task = response.get('task') + if not task: time.sleep(0.2) continue - data = response.json() + data = task.json() try: self.process(data['payload']) except Exception as exc: