Lines Matching refs:queue
40 def __init__(self, name, queue, wakeup_event): argument
67 …def assert_queue_outputs(self, queue, args=None, work_item=None, expected_stdout=None, expected_st… argument
86 queue.execute(options, args, tool, engine=MockQueueEngine)
88 …self.assert_outputs(queue.queue_log_path, "queue_log_path", [], expected_stdout, expected_stderr, …
89 …self.assert_outputs(queue.work_item_log_path, "work_item_log_path", [work_item], expected_stdout, …
90 …self.assert_outputs(queue.begin_work_queue, "begin_work_queue", [], expected_stdout, expected_stde…
91 …self.assert_outputs(queue.should_continue_work_queue, "should_continue_work_queue", [], expected_s…
92 …self.assert_outputs(queue.next_work_item, "next_work_item", [], expected_stdout, expected_stderr, …
93 …self.assert_outputs(queue.should_proceed_with_work_item, "should_proceed_with_work_item", [work_it…
94 …self.assert_outputs(queue.process_work_item, "process_work_item", [work_item], expected_stdout, ex…
95 …self.assert_outputs(queue.handle_unexpected_error, "handle_unexpected_error", [work_item, "Mock er…
97 if isinstance(queue, StepSequenceErrorHandler):
98 …self.assert_outputs(queue.handle_script_error, "handle_script_error", [tool, {"patch": self.mock_w…