adapt to new async update structure
This commit is contained in:
@@ -99,7 +99,8 @@ class Eiger500KSetup(CustomDetectorMixin):
|
||||
|
||||
# publish timeseries data
|
||||
metadata = self.parent.scaninfo.scan_msg.metadata
|
||||
metadata.update({"async_update": "append", "num_lines": self.parent.roistat.ts_current_point.get()})
|
||||
metadata.update({"async_update": "append", "max_shape": [None, None]})
|
||||
|
||||
msg = messages.DeviceMessage(
|
||||
signals={
|
||||
self.parent.roistat.roi1.name_.get(): {
|
||||
|
||||
@@ -136,7 +136,7 @@ class HklFlyScan(AsyncFlyScanBase):
|
||||
logger.success(f'{self.scan_name} finished')
|
||||
|
||||
def _publish_readbacks(self, device, readbacks):
|
||||
metadata = {"async_update": "append", "num_lines": len(readbacks)}
|
||||
metadata = {"async_update": "append", "max_shape": [None, None]}
|
||||
msg = messages.DeviceMessage(
|
||||
signals={device: {'value': readbacks} }, metadata=metadata
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user