Queue Operations

Queue management operations.

async shared.database.operations.queue.add_task_to_queue(task)[source]

Add task to processing queue with appropriate priority.

Parameters:

task (UserTask) – UserTask instance to queue

Return type:

TaskQueue

Returns:

TaskQueue entry

async shared.database.operations.queue.get_next_task_from_queue()[source]

Get next task from queue for processing.

Return type:

Optional[UserTask]

Returns:

Next UserTask to process or None if queue is empty

async shared.database.operations.queue.update_queue_positions()[source]

Update queue positions for all pending tasks based on priority and creation time.

Return type:

None