self/botalka
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: self:f0399196b561bfab7a10155ebcc81919eedec0b6
Branches Tags
self:master
self:prod
self:metric
self:dev
..
compare: self:7b806075c7c70bcafbc5490c52b8de9af78ad9d1
Branches Tags
self:master
self:prod
self:metric
self:dev

No commits in common. "f0399196b561bfab7a10155ebcc81919eedec0b6" and "7b806075c7c70bcafbc5490c52b8de9af78ad9d1" have entirely different histories.
f0399196b5 ... 7b806075c7

1 changed files with 1 additions and 3 deletions
Show Stats Expand all files Collapse all files

4
utils/queues.py
View File

@ -2,8 +2,6 @@ import time
import tasks_pb2_grpc import tasks_pb2_grpc
import tasks_pb2 import tasks_pb2
from google.protobuf import json_format
class QueuesException(Exception): class QueuesException(Exception):
... ...
@ -18,7 +16,7 @@ class TasksHandlerMixin:
time.sleep(0.2) time.sleep(0.2)
continue continue
try: try:
self.process(json_format.MessageToDict(task.payload)) self.process(task.payload)
except Exception as exc: 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={task["payload"]}, exc={exc}')
continue continue