diff --git a/mpikat/effelsberg/edd/EDDDataStore.py b/mpikat/effelsberg/edd/EDDDataStore.py index 59af49d9057aa08cec6c6ed69cad391e45d52c6f..9ae5e2938cb06900f5536f60e346ba13b296023e 100644 --- a/mpikat/effelsberg/edd/EDDDataStore.py +++ b/mpikat/effelsberg/edd/EDDDataStore.py @@ -33,8 +33,8 @@ data_formats = { "port": "", "description": "Spead stream of integrated spectra.", "central_freq": "", + "receiver_id": "", # Passign down all informations via the data format is only a hack as any product should not what to pass down from upstream to downstream. Only a full desciption of itself should be passed. If a data writer needs all information, it should recnstrut it from the entreis in the data store. "band_flip": "" - }, "MPIFR_EDD_Packetizer:1": { "ip": "", @@ -44,6 +44,7 @@ data_formats = { "sync_time" : 0, "band_flip": False, "central_freq": 0, + "receiver_id": "", "polarization": None, "samples_per_heap": 4096, "description": "Spead stream of time-domain packetizer data as in EDD ICD." diff --git a/mpikat/effelsberg/edd/pipeline/GatedSpectrometerPipeline.py b/mpikat/effelsberg/edd/pipeline/GatedSpectrometerPipeline.py index cbcd58445fa08dde05c3232eb531f314b5c22fcb..cb6935b38ddfd41940d0ec3b1e3ce8ac5b82b9aa 100644 --- a/mpikat/effelsberg/edd/pipeline/GatedSpectrometerPipeline.py +++ b/mpikat/effelsberg/edd/pipeline/GatedSpectrometerPipeline.py @@ -437,6 +437,7 @@ class GatedSpectrometerPipeline(EDDPipeline): for l in self._config["output_data_streams"].values(): l["central_freq"] = self._config["input_data_streams"][0]["central_freq"] l["band_flip"] = self._config["input_data_streams"][0]["band_flip"] + l["receiver_id"] = self._config["input_data_streams"][0]["receiver_id"] self._configUpdated()