Method get_task

app/queues/task_queue.py:45–51

(self, timeout=1)

        self.put(task)

    def get_task(self, timeout=1) -> Optional[TaskQueueItem]:
        try:
            raw_item = super().get(raw=True, block=True, timeout=timeout)
            return TaskQueueItem(queue_item_id=raw_item['pqid'], task=raw_item['data'])

        except Empty:
            return None