diff --git a/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py b/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py index 46a64a916dd5ef3a6ee7c57bc493ed51462783fa..b61ea593292a82670886653e4f7abc06b6049be8 100644 --- a/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py +++ b/CEP/Pipeline/recipes/sip/bin/calibration_pipeline.py @@ -236,6 +236,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 4cadbf9dd0e9d15b3be8169285067e5b4c600065..9295904d869dbb606a24cd68370ec10308dababc 100644 --- a/CEP/Pipeline/recipes/sip/bin/preprocessing_pipeline.py +++ b/CEP/Pipeline/recipes/sip/bin/preprocessing_pipeline.py @@ -192,6 +192,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