Lines Matching refs:Queue
34 from model.queues import Queue
43 # FIXME: This queue lookup should be shared between handlers.
44 queue = Queue.queue_with_name(queue_name)
45 if not queue:
51 last_status = attachment.status_for_queue(queue)
56 # Only remove it from the queue if the last message is not a retry request.
57 # Allow removing it from the queue even if there is no last_status for easier testing.
59 queue.work_items().remove_work_item(attachment_id)
62 queue.active_work_items().expire_item(attachment_id)
