Skip to content
Snippets Groups Projects
Commit 3cd475c6 authored by David Hammer's avatar David Hammer
Browse files

Only update output channel part of schema

parent f986d186
No related branches found
No related tags found
2 merge requests!12Snapshot: field test deployed version as of end of run 202201,!3Base correction device, CalCat interaction, DSSC and AGIPD devices
......@@ -774,16 +774,17 @@ class DsscCorrection(calibrationBase.CalibrationReceiverBaseDevice):
"""
self.log.INFO("Updating the output schema based on actual outgoing data")
my_schema = self.getFullSchema()
self.log.INFO("Updating output schema")
my_schema_update = Schema()
data_schema = hashToSchema.HashToSchema(data).schema
OUTPUT_CHANNEL(my_schema).key("dataOutput").dataSchema(data_schema).commit()
my_config = copy.copy(self.getCurrentConfiguration())
self.updateSchema(my_schema)
self.log.INFO("Re-applying backed up config")
self.set(my_config)
(
OUTPUT_CHANNEL(my_schema_update)
.key("dataOutput")
.dataSchema(data_schema)
.commit()
)
self.updateSchema(my_schema_update)
self._has_set_output_schema = True
self.log.INFO("Ready to continue")
def _update_pulse_filter(self, filter_string):
"""Called whenever the pulse filter changes, typically followed by
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment