From bb4c6d4748ee56cb0fe10ee83d61b76f8196c41b Mon Sep 17 00:00:00 2001
From: emmatveev <emmtvv@gmail.com>
Date: Sun, 8 Dec 2024 11:35:54 +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 43ead5e..c1028ff 100644
--- a/utils/queues.py
+++ b/utils/queues.py
@@ -18,9 +18,10 @@ class TasksHandlerMixin:
                 time.sleep(0.2)
                 continue
             try:
-                self.process(json_format.MessageToDict(task.payload))
+                payload = json_format.MessageToDict(task.payload)
+                self.process(payload)
             except Exception as exc:
-                print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}')
+                print(f'Error processing message id={task.id}, payload={payload}, exc={exc}')
                 continue
             try:
                 self.stub.Finish(tasks_pb2.FinishRequest(id=task.id))