Skip to content
Snippets Groups Projects
Commit 08707a18 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

TMSS-418: fixed test

parent 74adf0e0
No related branches found
No related tags found
1 merge request!355Resolve TMSS-418
......@@ -68,7 +68,7 @@ class TestSubtaskSchedulingService(unittest.TestCase):
from lofar.sas.tmss.services.tmss_postgres_listener import TMSSPGListener, TMSS_SUBTASK_OBJECT_EVENT_PREFIX, \
TMSS_SUBTASK_STATUS_EVENT_PREFIX, TMSS_TASKBLUEPRINT_OBJECT_EVENT_PREFIX, TMSS_TASKBLUEPRINT_STATUS_EVENT_PREFIX, \
TMSS_TASKDRAFT_OBJECT_EVENT_PREFIX, TMSS_SCHEDULINGUNITBLUEPRINT_OBJECT_EVENT_PREFIX, \
TMSS_SCHEDULINGUNITBLUEPRINT_STATUS_EVENT_PREFIX, TMSS_SCHEDULINGUNITDRAFT_OBJECT_EVENT_PREFIX
TMSS_SCHEDULINGUNITBLUEPRINT_STATUS_EVENT_PREFIX, TMSS_SCHEDULINGUNITDRAFT_OBJECT_EVENT_PREFIX, TMSS_PROJECT_OBJECT_EVENT_PREFIX
class TestTMSSPGListener(TMSSPGListener):
'''Helper TMSSPGListener for this test, storing intermediate results, and providing synchronization threading.Events'''
......@@ -88,8 +88,17 @@ class TestSubtaskSchedulingService(unittest.TestCase):
# create and start the service (the object under test)
with TestTMSSPGListener(exchange=self.tmp_exchange.address, dbcreds=self.tmss_test_env.database.dbcreds) as service:
# create a Project
project = self.test_data_creator.post_data_and_get_response_as_json_object(self.test_data_creator.Project(), '/project/')
# sync and check
with service.lock:
self.assertEqual(TMSS_PROJECT_OBJECT_EVENT_PREFIX +'.Created', service.subjects.popleft())
self.assertEqual({"name": project['name']}, service.contentDicts.popleft())
# create a SchedulingUnitDraft
su_draft = self.test_data_creator.post_data_and_get_response_as_json_object(self.test_data_creator.SchedulingUnitDraft(), '/scheduling_unit_draft/')
scheduling_set_url = self.test_data_creator.post_data_and_get_url(self.test_data_creator.SchedulingSet(project_url=project['url']), '/scheduling_set/')
su_draft = self.test_data_creator.post_data_and_get_response_as_json_object(self.test_data_creator.SchedulingUnitDraft(scheduling_set_url=scheduling_set_url), '/scheduling_unit_draft/')
# sync and check
with service.lock:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment