Handle Aviti Teton FlowcellPressureCheck directories

VERSIONLOG.md

@@ -1,5 +1,9 @@
 # TACA Version Log
 
+## 20251010.2
+
+Move Aviti Teton FlowcellPressureCheck directories into run directory before processing the run
+
 ## 20251010.1
 
 Adapt analysis demultiplex-element to handle NULISA runs

taca/__init__.py

@@ -1,3 +1,3 @@
 """Main TACA module"""
 
-__version__ = "1.6.9"
+__version__ = "1.6.10"

taca/analysis/analysis_element.py

@@ -123,7 +123,9 @@ def _process(run_to_process):
         #### Transfer status ####
         transfer_status = run.get_transfer_status()
         if transfer_status == "not started":
-            if not run.run_type == "Cytoprofiling":
+            if run.run_type == "Cytoprofiling":
+                run.move_pressure_check_dir()
+            else:
                 demux_results_dirs = glob.glob(
                     os.path.join(run.run_dir, "Demultiplexing_*")
                 )

taca/element/Element_Runs.py

@@ -284,7 +284,9 @@ def parse_run_parameters(self) -> None:
             "RunType"
         )  # Sequencing, Cytoprofiling, wash or prime
         if self.run_type == "Cytoprofiling":
-            self.flowcell_id = self.run_name  # Teton runs don't have FlowcellID in the RunParameters.json, the PID is used instead
+            self.flowcell_id = self.run_name[
+                1:
+            ]  # Teton runs don't have FlowcellID in the RunParameters.json, the PID is used instead
         else:
             self.flowcell_id = run_parameters.get("FlowcellID")
         self.cycles = run_parameters.get("Cycles", {"R1": 0, "R2": 0, "I1": 0, "I2": 0})
@@ -828,6 +830,16 @@ def rsync_successful(self):
         else:
             return False
 
+    def move_pressure_check_dir(self):
+        pressure_check_dir = self.run_dir + "_FlowcellPressureCheck"
+        if os.path.exists(pressure_check_dir):
+            shutil.move(pressure_check_dir, self.run_dir)
+            logger.info(f"Moved pressure check dir to {self.run_dir}")
+        else:
+            logger.info(
+                f"No pressure check dir found for {self}. Processing run anyway."
+            )
+
     # Clear all content under a dir
     def clear_dir(self, dir):
         for filename in os.listdir(dir):