Lines Matching refs:queue
40 def _rows_for_work_items(self, queue):
41 queued_items = queue.work_items()
42 active_items = queue.active_work_items()
60 def _fetch_statuses(self, queue, bot_id):
62 statuses.filter("queue_name =", queue.name())
67 def _fetch_last_message_matching(self, queue, bot_id, message):
69 statuses.filter("queue_name =", queue.name())
75 def _fetch_trailing_days_pass_count(self, queue, bot_id, days):
77 statuses.filter("queue_name =", queue.name())
85 def _page_title(self, queue, bot_id):
86 title = "%s Messages" % queue.display_name()
93 queue = Queue.queue_with_name(queue_name)
94 if not queue:
98 statuses = self._fetch_statuses(queue, bot_id)
100 "page_title": self._page_title(queue, bot_id),
101 "work_item_rows": self._rows_for_work_items(queue),
104 "last_pass": self._fetch_last_message_matching(queue, bot_id, "Pass"),
105 "last_boot": self._fetch_last_message_matching(queue, bot_id, "Starting Queue"),
106 "trailing_month_pass_count": self._fetch_trailing_days_pass_count(queue, bot_id, 30),
107 "trailing_week_pass_count": self._fetch_trailing_days_pass_count(queue, bot_id, 7),