Ruff format

VERSIONLOG.md

@@ -1,6 +1,10 @@
 # TACA Version Log
 
-## 20241216.1
+## 20250122.1
+
+Ruff formatting.
+
+## 20241216.2
 
 Do not run ToulligQC if its output directory can be found.
 

taca/cleanup/cleanup.py

@@ -571,13 +571,13 @@ def _def_get_size_unit(s):
     gb = mb * 1000
     tb = gb * 1000
     if s > tb:
-        s = f"~{int(s/tb)}tb"
+        s = f"~{int(s / tb)}tb"
     elif s > gb:
-        s = f"~{int(s/gb)}gb"
+        s = f"~{int(s / gb)}gb"
     elif s > mb:
-        s = f"~{int(s/mb)}mb"
+        s = f"~{int(s / mb)}mb"
     elif s > kb:
-        s = f"~{int(s/kb)}kb"
+        s = f"~{int(s / kb)}kb"
     elif s > 0:
         s = f"~{int(s)}b"
     return str(s)

taca/element/Element_Runs.py

@@ -437,9 +437,9 @@ def make_demux_manifests(
 
         # Get '[SAMPLES]' section
         split_contents = manifest_contents.split("[SAMPLES]")
-        assert (
-            len(split_contents) == 2
-        ), f"Could not split sample rows out of manifest {manifest_contents}"
+        assert len(split_contents) == 2, (
+            f"Could not split sample rows out of manifest {manifest_contents}"
+        )
         sample_section = split_contents[1].strip().split("\n")
 
         # Split into header and rows
@@ -560,7 +560,7 @@ def make_demux_manifests(
                     "[RUNVALUES]",
                     "KeyName, Value",
                     f"manifest_file, {file_name}",
-                    f"manifest_group, {n+1}/{len(grouped_df)}",
+                    f"manifest_group, {n + 1}/{len(grouped_df)}",
                     f"built_from, {manifest_to_split}",
                 ]
             )

taca/nanopore/ONT_run_classes.py

@@ -37,9 +37,9 @@ def __init__(self, run_abspath: str):
             None  # This will be defined upon instantiation of a child class
         )
 
-        assert re.match(
-            ONT_RUN_PATTERN, self.run_name
-        ), f"Run {self.run_name} doesn't look like a run dir"
+        assert re.match(ONT_RUN_PATTERN, self.run_name), (
+            f"Run {self.run_name} doesn't look like a run dir"
+        )
 
         # Parse MinKNOW sample and experiment name
         with open(self.get_file("/run_path.txt")) as stream:
@@ -143,9 +143,9 @@ def touch_db_entry(self):
             pore_count_history_file = os.path.join(
                 self.run_abspath, "pore_count_history.csv"
             )
-            assert os.path.isfile(
-                pore_count_history_file
-            ), f"Couldn't find {pore_count_history_file}"
+            assert os.path.isfile(pore_count_history_file), (
+                f"Couldn't find {pore_count_history_file}"
+            )
 
             self.db.create_ongoing_run(self, run_path_file, pore_count_history_file)
             logger.info(

taca/utils/misc.py

@@ -176,7 +176,7 @@ def query_yes_no(question, default="yes", force=False):
         elif choice in valid:
             return valid[choice]
         else:
-            sys.stdout.write('Please respond with "yes" or "no" ' '(or "y" or "n").\n')
+            sys.stdout.write('Please respond with "yes" or "no" (or "y" or "n").\n')
 
 
 def return_unique(seq):

taca/utils/statusdb.py

@@ -225,8 +225,7 @@ def merge_dicts(d1, d2):
                 pass  # same leaf value
             else:
                 logger.debug(
-                    f"Values for key {key} in d1 and d2 differ, "
-                    "using the value of d1"
+                    f"Values for key {key} in d1 and d2 differ, using the value of d1"
                 )
         else:
             d1[key] = d2[key]

taca/utils/transfer.py

@@ -269,7 +269,7 @@ def transfer(self):
             # If we are not overwriting, return False
             if not self.overwrite:
                 logger.debug(
-                    f'target "{self.dest_path}" exists and will not be ' "overwritten"
+                    f'target "{self.dest_path}" exists and will not be overwritten'
                 )
                 return False
             # If the target is a mount, let's not mess with it

tests/nanopore/test_ONT_run_classes.py

@@ -171,7 +171,7 @@ def create_ONT_run_dir(
                     "unknown_positive",
                     "zero",
                 ]:
-                    f.write(f"{state},{i},{i*100}\n")
+                    f.write(f"{state},{i},{i * 100}\n")
 
     if sync_finished:
         open(f"{run_path}/.sync_finished", "w").close()

tests/nanopore/test_instrument_transfer.py

@@ -398,15 +398,15 @@ def test_dump_pore_count_history(setup_test_fixture):
 
     # Nothing to add, no file
     tmp = tempfile.TemporaryDirectory()
-    run_path = tmp.name + f"/experiment/sample/{DUMMY_RUN_NAME.replace('TEST','FLG')}"
+    run_path = tmp.name + f"/experiment/sample/{DUMMY_RUN_NAME.replace('TEST', 'FLG')}"
     os.makedirs(run_path)
     new_file = instrument_transfer.dump_pore_count_history(run_path, pore_counts)
     assert open(new_file).read() == ""
     tmp.cleanup()
 
     # Nothing to add, file is present
     tmp = tempfile.TemporaryDirectory()
-    run_path = tmp.name + f"/experiment/sample/{DUMMY_RUN_NAME.replace('TEST','FLG')}"
+    run_path = tmp.name + f"/experiment/sample/{DUMMY_RUN_NAME.replace('TEST', 'FLG')}"
     os.makedirs(run_path)
     open(run_path + "/pore_count_history.csv", "w").write("test")
     new_file = instrument_transfer.dump_pore_count_history(run_path, pore_counts)