add test_job_process_event unit test cases

Change-Id: Ifcef7876c3b1930ebd1237e9c1264db8278e332e
This commit is contained in:
gecong1973 2021-02-07 00:50:11 -08:00
parent ca74ddf145
commit 98b12b02e0
1 changed files with 26 additions and 0 deletions

View File

@ -188,3 +188,29 @@ class TestSchedulerJob1(unittest.TestCase):
job1 = scheduler_job.Job(self.scheduler, None, jobdoc1)
result = job1.get_schedule_args()
self.assertEqual(result.get('trigger'), 'date')
def test_job_process_event(self):
jobdoc1 = {"job_id": "test", "job_schedule": {"event": "start",
"status": "start"}}
result = self.job.process_event(jobdoc1)
self.assertIsNone(result)
jobdoc1 = {"job_id": "test", "job_schedule": {"event": "stop",
"status": "start"}}
result = self.job.process_event(jobdoc1)
self.assertIsNone(result)
jobdoc1 = {"job_id": "test", "job_schedule": {"event": "abort",
"status": "start"}}
result = self.job.process_event(jobdoc1)
self.assertIsNone(result)
jobdoc1 = {"job_id": "test", "job_schedule": {"event": "aborted",
"status": "start"}}
result = self.job.process_event(jobdoc1)
self.assertIsNone(result)
def test_job_upload_metadata(self):
metatring = '{"test": "freezer"}'
self.job.upload_metadata(metatring)
self.assertTrue(self.scheduler.upload_metadata.called)
metatring = ''
result = self.job.upload_metadata(metatring)
self.assertIsNone(result)