diff --git a/utils/queues.py b/utils/queues.py index c1028ff..85a4e63 100644 --- a/utils/queues.py +++ b/utils/queues.py @@ -14,6 +14,7 @@ class TasksHandlerMixin: while True: response: tasks_pb2.TakeResponse = self.stub.Take(tasks_pb2.TakeRequest(queue=self.queue_name)) task: tasks_pb2.Task = response.task + print(task) if not task: time.sleep(0.2) continue