Lines Matching full:self
39 def __init__(self, test):
40 self._test = test
41 self._callbacks = []
42 self._run_before = False
55 def record(self, method_name):
56 self._callbacks.append(method_name)
58 def queue_log_path(self):
59 self.record("queue_log_path")
60 return os.path.join(self._test.temp_dir, "queue_log_path")
62 def work_item_log_path(self, work_item):
63 self.record("work_item_log_path")
64 return os.path.join(self._test.temp_dir, "work_log_path", "%s.log" % work_item)
66 def begin_work_queue(self):
67 self.record("begin_work_queue")
69 def should_continue_work_queue(self):
70 self.record("should_continue_work_queue")
71 if not self._run_before:
72 self._run_before = True
76 def next_work_item(self):
77 self.record("next_work_item")
80 def should_proceed_with_work_item(self, work_item):
81 self.record("should_proceed_with_work_item")
82 self._test.assertEquals(work_item, "work_item")
86 def process_work_item(self, work_item):
87 self.record("process_work_item")
88 self._test.assertEquals(work_item, "work_item")
90 def handle_unexpected_error(self, work_item, message):
91 self.record("handle_unexpected_error")
92 self._test.assertEquals(work_item, "work_item")
96 def __init__(self, test, error_code):
97 LoggingDelegate.__init__(self, test)
98 self.error_code = error_code
100 def process_work_item(self, work_item):
101 self.record("process_work_item")
102 raise ScriptError(exit_code=self.error_code)
106 def should_proceed_with_work_item(self, work_item):
107 self.record("should_proceed_with_work_item")
108 self._test.assertEquals(work_item, "work_item")
113 def __init__(self, delegate):
114 QueueEngine.__init__(self, "fast-queue", delegate)
119 def _sleep(self, message):
124 def test_trivial(self):
125 delegate = LoggingDelegate(self)
128 self.assertEquals(delegate._callbacks, LoggingDelegate.expected_callbacks)
129 self.assertTrue(os.path.exists(os.path.join(self.temp_dir, "queue_log_path")))
130 self.assertTrue(os.path.exists(os.path.join(self.temp_dir, "work_log_path", "work_item.log")))
132 def test_unexpected_error(self):
133 delegate = ThrowErrorDelegate(self, 3)
141 self.assertEquals(delegate._callbacks, expected_callbacks)
143 def test_handled_error(self):
144 delegate = ThrowErrorDelegate(self, QueueEngine.handled_error_code)
147 self.assertEquals(delegate._callbacks, LoggingDelegate.expected_callbacks)
149 def test_not_safe_to_proceed(self):
150 delegate = NotSafeToProceedDelegate(self)
160 self.assertEquals(delegate._callbacks, expected_callbacks)
162 def setUp(self):
163 self.temp_dir = tempfile.mkdtemp(suffix="work_queue_test_logs")
165 def tearDown(self):
166 shutil.rmtree(self.temp_dir)
