bec/ophyd_devices
0
0
Fork 0
mirror of https://github.com/bec-project/ophyd_devices.git synced 2025-05-24 17:30:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: device_status should use set

Browse Source
This commit is contained in:
wakonig_k 2024-03-05 16:25:13 +01:00
parent afd7912329
commit 6d179ea8a8
5 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ophyd_devices/rt_lamni/rt_flomni_ophyd.py
View File

@ -425,7 +425,7 @@ class RtFlomniController(RtController):
# if not (mode==2 or mode==3):
# error
self.get_device_manager().connector.set_and_publish(
self.get_device_manager().connector.set(
MessageEndpoints.device_status("rt_scan"),
messages.DeviceStatusMessage(
device="rt_scan", status=1, metadata=self.readout_metadata
@ -460,7 +460,7 @@ class RtFlomniController(RtController):
signals = self._get_signals_from_table(return_table)
self.publish_device_data(signals=signals, pointID=int(return_table[0]))
self.get_device_manager().connector.set_and_publish(
self.get_device_manager().connector.set(
MessageEndpoints.device_status("rt_scan"),
messages.DeviceStatusMessage(
device="rt_scan", status=0, metadata=self.readout_metadata

4
ophyd_devices/rt_lamni/rt_lamni_ophyd.py
View File

@ -385,7 +385,7 @@ class RtLamniController(Controller):
# if not (mode==2 or mode==3):
# error
self.get_device_manager().connector.set_and_publish(
self.get_device_manager().connector.set(
MessageEndpoints.device_status("rt_scan"),
messages.DeviceStatusMessage(
device="rt_scan", status=1, metadata=self.readout_metadata
@ -420,7 +420,7 @@ class RtLamniController(Controller):
signals = self._get_signals_from_table(return_table)
self.publish_device_data(signals=signals, pointID=int(return_table[0]))
self.get_device_manager().connector.set_and_publish(
self.get_device_manager().connector.set(
MessageEndpoints.device_status("rt_scan"),
messages.DeviceStatusMessage(
device="rt_scan", status=0, metadata=self.readout_metadata

4
ophyd_devices/rt_lamni/rt_ophyd.py
View File

@ -355,7 +355,7 @@ class RtController(Controller):
# if not (mode==2 or mode==3):
# error
self.get_device_manager().connector.set_and_publish(
self.get_device_manager().connector.set(
MessageEndpoints.device_status("rt_scan"),
messages.DeviceStatusMessage(
device="rt_scan", status=1, metadata=self.readout_metadata
@ -390,7 +390,7 @@ class RtController(Controller):
signals = self._get_signals_from_table(return_table)
self.publish_device_data(signals=signals, pointID=int(return_table[0]))
self.get_device_manager().connector.set_and_publish(
self.get_device_manager().connector.set(
MessageEndpoints.device_status("rt_scan"),
messages.DeviceStatusMessage(
device="rt_scan", status=0, metadata=self.readout_metadata

4
ophyd_devices/sim/sim.py
View File

@ -526,7 +526,7 @@ class SimFlyer(Device, PositionerBase, FlyerInterface):
MessageEndpoints.device_read(device.name), bundle
)
bundle = messages.BundleMessage()
device.device_manager.connector.set_and_publish(
device.device_manager.connector.set(
MessageEndpoints.device_status(device.name),
messages.DeviceStatusMessage(
device=device.name, status=1, metadata={"pointID": ii, **metadata}
@ -535,7 +535,7 @@ class SimFlyer(Device, PositionerBase, FlyerInterface):
device.device_manager.connector.set_and_publish(
MessageEndpoints.device_read(device.name), bundle
)
device.device_manager.connector.set_and_publish(
device.device_manager.connector.set(
MessageEndpoints.device_status(device.name),
messages.DeviceStatusMessage(
device=device.name, status=0, metadata={"pointID": num_pos, **metadata}

4
ophyd_devices/sim/sim_test_devices.py
View File

@ -133,14 +133,14 @@ class SynFlyerLamNI(Device, PositionerBase):
MessageEndpoints.device_read(device.name), bundle
)
bundle = messages.BundleMessage()
device.device_manager.connector.set_and_publish(
device.device_manager.connector.set(
MessageEndpoints.device_status(device.name),
messages.DeviceStatusMessage(
device=device.name, status=1, metadata={"pointID": ii, **metadata}
),
)
device.device_manager.connector.send(MessageEndpoints.device_read(device.name), bundle)
device.device_manager.connector.set_and_publish(
device.device_manager.connector.set(
MessageEndpoints.device_status(device.name),
messages.DeviceStatusMessage(
device=device.name, status=0, metadata={"pointID": num_pos, **metadata}