From d9d2fb0f23a71edc630d920fbaa6cfd58b3118c1 Mon Sep 17 00:00:00 2001 From: gac-x04sa Date: Wed, 23 Apr 2025 10:17:25 +0200 Subject: [PATCH] adapt to new async update structure --- addams_bec/devices/detector.py | 3 ++- addams_bec/scans/fly_scan.py | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/addams_bec/devices/detector.py b/addams_bec/devices/detector.py index 4580a08..974f508 100644 --- a/addams_bec/devices/detector.py +++ b/addams_bec/devices/detector.py @@ -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(): { diff --git a/addams_bec/scans/fly_scan.py b/addams_bec/scans/fly_scan.py index cd8623f..913a179 100644 --- a/addams_bec/scans/fly_scan.py +++ b/addams_bec/scans/fly_scan.py @@ -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 )