diff --git a/utils/queues.py b/utils/queues.py index 9701634..31767e5 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -15,7 +15,8 @@ class TasksHandlerMixin: response: tasks_pb2.TakeResponse = self.stub.Take(tasks_pb2.TakeRequest(queue=self.queue_name)) task = response.task if not task: - time.sleep(0.2) + if response.retry_after: + time.sleep(response.retry_after) continue try: payload = json_format.MessageToDict(task.payload)