From 5e6c6152023daf2d3f3fd0c638bfb81c9d4f411b Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Tue, 2 Nov 2021 14:43:05 +0100
Subject: [PATCH] TMSS-1124: fixed test
---
SAS/TMSS/backend/test/t_scheduling_units.py | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/SAS/TMSS/backend/test/t_scheduling_units.py b/SAS/TMSS/backend/test/t_scheduling_units.py
index 90415b654f7..b5d7eb0e6cc 100644
--- a/SAS/TMSS/backend/test/t_scheduling_units.py
+++ b/SAS/TMSS/backend/test/t_scheduling_units.py
@@ -615,6 +615,10 @@ class SchedulingUnitBlueprintIndirectModificationsTestCase(unittest.TestCase):
client.schedule_subtask(subtask_pipe['id'], datetime.utcnow())
pipe_input_dataproducts = client.get_subtask_input_dataproducts(subtask_pipe['id'])
self.assertTrue(len(pipe_input_dataproducts) > 0)
+
+ # fetch obs_output_dataproducts again, as they "changed" now that the pipeline was scheduled: the contain a reference to a consumer (the subtaskinput of the pipeline)
+ obs_output_dataproducts = client.get_subtask_output_dataproducts(subtask_obs['id'])
+ self.assertTrue(len(obs_output_dataproducts) > 0)
self.assertEqual(obs_output_dataproducts, pipe_input_dataproducts)
# and simulate that it runs and errors
@@ -641,6 +645,10 @@ class SchedulingUnitBlueprintIndirectModificationsTestCase(unittest.TestCase):
# check the copy's dataproducts
copy_subtask_pipe_input_dataproducts = client.get_subtask_input_dataproducts(copy_subtask_pipe['id'])
self.assertTrue(len(copy_subtask_pipe_input_dataproducts) > 0)
+
+ # fetch obs_output_dataproducts and pipe_input_dataproducts again, as they "changed" now that the copy-pipeline was scheduled: the contain a reference to a consumer (the subtaskinput of the pipeline)
+ obs_output_dataproducts = client.get_subtask_output_dataproducts(subtask_obs['id'])
+ pipe_input_dataproducts = client.get_subtask_input_dataproducts(subtask_pipe['id'])
self.assertEqual(pipe_input_dataproducts, copy_subtask_pipe_input_dataproducts)
self.assertEqual(obs_output_dataproducts, copy_subtask_pipe_input_dataproducts)
--
GitLab