w
CI for csaxs_bec / test (push) Successful in 1m25s
CI for csaxs_bec / test (pull_request) Successful in 1m32s

This commit is contained in:
2026-01-15 10:30:30 +01:00
parent 01e7fc03ef
commit 51fc140150
@@ -286,7 +286,13 @@ class MCSCardCSAXS(PSIDeviceBase, MCSCard):
)
# Once we have received all channels, push data to BEC and reset for next accumulation
logger.info(
f"Received update for {attr_name}, index {self._mca_counter_index}/{self.NUM_MCA_CHANNELS}"
)
if len(self._current_data) == self.NUM_MCA_CHANNELS:
logger.info(
f"Current data index {self._current_data_index} complete, pushing to BEC."
)
self.mca.put(self._current_data, acquisition_group=self._acquisition_group)
self._current_data.clear()
self._mca_counter_index = 0
@@ -406,6 +412,7 @@ class MCSCardCSAXS(PSIDeviceBase, MCSCard):
while not self._scan_done_thread_kill_event.is_set():
while self._start_monitor_async_data_emission.wait():
try:
logger.info(f"Monitoring async data emission for {self.name}...")
if self.scan_info is not None:
if self._current_data_index == self.scan_info.msg.num_points:
for callback in self._scan_done_callbacks: