Compare commits
No commits in common. "8f47b7643ecafb0b18e7a6ba558ed202837e5d55" and "90e194fa506cfe8cfbeeb6a2abfd2618da1d3083" have entirely different histories.
8f47b7643e
...
90e194fa50
@ -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)
|
||||
|
Loading…
Reference in New Issue
Block a user