Compare commits

..

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

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))