bec/tomcat_bec
0
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
wakonig_k
2025-06-17 11:08:10 +02:00
parent 5699363acf
commit da9004b487
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
tomcat_bec/devices/pco_edge/pcoedgecamera.py
View File

@@ -125,6 +125,7 @@ class PcoEdge5M(PSIDeviceBase, PcoEdgeBase):
self.backend.add_count_callback(self._on_count_update) self.backend.add_count_callback(self._on_count_update)
self.live_preview = None self.live_preview = None
self.converted_files = deque(maxlen=100) # Store the last 10 converted files self.converted_files = deque(maxlen=100) # Store the last 10 converted files
self.target_files = deque(maxlen=100) # Store the last 10 target files
self.acq_configs = {} self.acq_configs = {}
if std_daq_live is not None: if std_daq_live is not None:
self.live_preview = StdDaqPreview(url=std_daq_live, cb=self._on_preview_update) self.live_preview = StdDaqPreview(url=std_daq_live, cb=self._on_preview_update)
@@ -361,6 +362,7 @@ class PcoEdge5M(PSIDeviceBase, PcoEdgeBase):
num_images=self.num_images.get(), # type: ignore num_images=self.num_images.get(), # type: ignore
) )
self.camera_status.set(CameraStatus.RUNNING).wait() self.camera_status.set(CameraStatus.RUNNING).wait()
self.target_files.append(self.target_file)
def is_running(*, value, timestamp, **_): def is_running(*, value, timestamp, **_):
return bool(value == CameraStatusCode.RUNNING) return bool(value == CameraStatusCode.RUNNING)
@@ -541,11 +543,11 @@ class PcoEdge5M(PSIDeviceBase, PcoEdgeBase):
"""Called to inquire if a device has completed a scans.""" """Called to inquire if a device has completed a scans."""
def _create_dataset(_status: DeviceStatus): def _create_dataset(_status: DeviceStatus):
if self.target_file in self.converted_files: if (
logger.info( self.target_file in self.converted_files
f"File {self.target_file} already exists in the converted files list. " or self.target_file not in self.target_files
"Skipping dataset creation." ):
) logger.info(f"File {self.target_file} already processed or not in target files.")
return return
self.backend.create_virtual_datasets( self.backend.create_virtual_datasets(
self.file_path.get(), file_prefix=self.file_prefix.get() # type: ignore self.file_path.get(), file_prefix=self.file_prefix.get() # type: ignore