126
132
worker.run(quit_on_empty=True)
128
134
def test_ingest_job_contract(self):
129
135
# All ingest jobs accept the right inputs.
130
136
ingest_jobs = [create_autospec(job)() for job in DEFAULT_JOBS]
132
138
worker.run(quit_on_empty=True)
133
139
self.assertEqual(0, self.queue.size())
135
141
def test_interval_is_int(self):
137
143
self.assertIs(int, type(worker.interval),
138
144
'QueueWorker.interval is a %s, not an int.' %