From 0659ec01d16a826e5479328fe35f8fabffcf495f Mon Sep 17 00:00:00 2001 From: appel_c Date: Wed, 26 Feb 2025 18:25:16 +0100 Subject: [PATCH] fix: remove metadata updates on ScanStatusMessage --- ophyd_devices/sim/sim_monitor.py | 7 ++----- ophyd_devices/sim/sim_waveform.py | 4 +--- 2 files changed, 3 insertions(+), 8 deletions(-) diff --git a/ophyd_devices/sim/sim_monitor.py b/ophyd_devices/sim/sim_monitor.py index d4bb760..635df39 100644 --- a/ophyd_devices/sim/sim_monitor.py +++ b/ophyd_devices/sim/sim_monitor.py @@ -176,13 +176,10 @@ class SimMonitorAsync(PSIDeviceBase, SimMonitorAsyncControl): def _send_data_to_bec(self) -> None: """Sends bundled data to BEC""" - if self.scan_info.msg is None: - return - metadata = self.scan_info.msg.metadata - metadata.update({"async_update": self.async_update.get()}) + metadata = {"async_update": self.async_update.get()} msg = messages.DeviceMessage( - signals={self.readback.name: self.data_buffer}, metadata=self.scan_info.msg.metadata + signals={self.readback.name: self.data_buffer}, metadata=metadata ) self.connector.xadd( MessageEndpoints.device_async_readback( diff --git a/ophyd_devices/sim/sim_waveform.py b/ophyd_devices/sim/sim_waveform.py index aa43b30..e57fa3a 100644 --- a/ophyd_devices/sim/sim_waveform.py +++ b/ophyd_devices/sim/sim_waveform.py @@ -130,12 +130,10 @@ class SimWaveform(Device): def _send_async_update(self): """Send the async update to BEC.""" - metadata = self.scan_info.msg.metadata async_update_type = self.async_update.get() if async_update_type not in ["extend", "append"]: raise ValueError(f"Invalid async_update type: {async_update_type}") - metadata.update({"async_update": async_update_type}) - + metadata = {"async_update": async_update_type} msg = messages.DeviceMessage( signals={self.waveform.name: {"value": self.waveform.get(), "timestamp": time.time()}}, metadata=metadata,