From f036f521d86ae79903dedfc2f81bae36d788c2be Mon Sep 17 00:00:00 2001 From: emmatveev Date: Fri, 13 Dec 2024 02:08:36 +0300 Subject: [PATCH] fix --- utils/queues.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/utils/queues.py b/utils/queues.py index 31767e5..9701634 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -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)