From dc7c222f508664ee5a0f142b7e3e27cf4b7482cd Mon Sep 17 00:00:00 2001
From: emmatveev <emmtvv@gmail.com>
Date: Wed, 27 Nov 2024 02:33:09 +0300
Subject: [PATCH] fix

---
 utils/queues.py | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/utils/queues.py b/utils/queues.py
index 07f3c29..603e981 100644
--- a/utils/queues.py
+++ b/utils/queues.py
@@ -23,18 +23,17 @@ class TasksHandlerMixin:
             if not task:
                 time.sleep(0.2)
                 continue
-            data = task.json()
             try:
-                self.process(data['payload'])
+                self.process(task['payload'])
             except Exception as exc:
-                print(f'Error processing message id={data["id"]}, payload={data["payload"]}, exc={exc}')
+                print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}')
                 continue
             try:
                 resp = requests.post(f'{QUEUES_URL}/api/v1/finish', json={'id': data['id']})
                 if resp.status_code != 202:
                     raise QueuesException
             except:
-                print(f'Failed to finish task id={data["id"]}')
+                print(f'Failed to finish task id={task["id"]}')
 
     @property
     def queue_name(self):