def _get_tasks_queue(self) -> Queue:
    'All endpoints are distributed among all workers via a queue.'
    tasks_queue: Queue = Queue()
    tasks_queue.queue.extend(self.schema.get_all_endpoints())
    return tasks_queue
All endpoints are distributed among all workers via a queue.
def _get_tasks_queue(self) -> Queue:
    
    tasks_queue: Queue = Queue()
    tasks_queue.queue.extend(self.schema.get_all_endpoints())
    return tasks_queue