TMSS-1124: fixed test

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)