diff --git a/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py b/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py index 75f7c6d8066c5f57fe92ea54250e04c0acaf88ab..efd28a1951ff914a603ad8d59034f44711d4815a 100644 --- a/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py +++ b/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py @@ -234,6 +234,18 @@ class calibration_pipeline(control): sky_mapfile=sourcedb_mapfile ) + # ********************************************************************* + # 6. Create feedback file for further processing by the LOFAR framework + # (MAC) + # Create a parset-file containing the metadata for MAC/SAS + with duration(self, "get_metadata"): + self.run_task("get_metadata", output_data_mapfile, + parset_file=self.parset_feedback_file, + parset_prefix=( + self.parset.getString('prefix') + + self.parset.fullModuleName('DataProducts')), + product_type="Correlated") + return 0 diff --git a/CEP/Pipeline/recipes/sip/bin/preprocessing_pipeline.py b/CEP/Pipeline/recipes/sip/bin/preprocessing_pipeline.py index 61bbb0cde7b078000073a1105a268f422f67d1fd..cd482ba9070f01d30f5ef2c80ff8f658a621311a 100644 --- a/CEP/Pipeline/recipes/sip/bin/preprocessing_pipeline.py +++ b/CEP/Pipeline/recipes/sip/bin/preprocessing_pipeline.py @@ -190,6 +190,18 @@ class preprocessing_pipeline(control): data_end_time=vdsinfo['end_time'], parset=ndppp_parset) + # ********************************************************************* + # 6. Create feedback file for further processing by the LOFAR framework + # (MAC) + # Create a parset-file containing the metadata for MAC/SAS + with duration(self, "get_metadata"): + self.run_task("get_metadata", output_data_mapfile, + parset_file=self.parset_feedback_file, + parset_prefix=( + self.parset.getString('prefix') + + self.parset.fullModuleName('DataProducts')), + product_type="Correlated") + return 0