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

Compare commits

base: self:80462d2a61e03f89d0ab7ecb4b502548681bb924
Branches Tags
self:master
self:prod
self:metric
self:dev
..
compare: self:f0399196b561bfab7a10155ebcc81919eedec0b6
Branches Tags
self:master
self:prod
self:metric
self:dev

No commits in common. "80462d2a61e03f89d0ab7ecb4b502548681bb924" and "f0399196b561bfab7a10155ebcc81919eedec0b6" have entirely different histories.
80462d2a61 ... f0399196b5

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

5
utils/queues.py
View File

@ -18,10 +18,9 @@ class TasksHandlerMixin:
time.sleep(0.2)
continue
try:
payload = json_format.MessageToDict(task.payload)
self.process(payload)
self.process(json_format.MessageToDict(task.payload))
except Exception as exc:
print(f'Error processing message id={task.id}, payload={payload}, exc={exc}')
print(f'Error processing message id={task["id"]}, payload={task["payload"]}, exc={exc}')
continue
try:
self.stub.Finish(tasks_pb2.FinishRequest(id=task.id))