Compare commits

..

No commits in common. "8f47b7643ecafb0b18e7a6ba558ed202837e5d55" and "90e194fa506cfe8cfbeeb6a2abfd2618da1d3083" have entirely different histories.

View File

@ -15,8 +15,7 @@ class TasksHandlerMixin:
response: tasks_pb2.TakeResponse = self.stub.Take(tasks_pb2.TakeRequest(queue=self.queue_name))
task = response.task
if not task:
if response.retry_after:
time.sleep(response.retry_after)
time.sleep(0.2)
continue
try:
payload = json_format.MessageToDict(task.payload)