style: ruff check

Author: ttngu207

aeon/dj_pipeline/analysis/visit.py

@@ -6,8 +6,8 @@
 import datajoint as dj
 import numpy as np
 import pandas as pd
-
 from swc.aeon.analysis import utils as analysis_utils
+
 from aeon.dj_pipeline import acquisition, fetch_stream, get_schema_name
 
 schema = dj.schema(get_schema_name("analysis"))

aeon/dj_pipeline/subject.py

@@ -521,9 +521,8 @@ def associate_subject_and_experiment(subject_name):
                   & "content LIKE 'experiment:%'").fetch(as_dict=True):
         entry.pop("comment_id")
         entry["experiment_name"] = entry.pop("content").replace("experiment:", "").strip()
-        if acquisition.Experiment.proj() & entry:
-            if not acquisition.Experiment.Subject & entry:
-                new_entries.append(entry)
-                logger.info(f"\tNew experiment subject: {entry}")
+        if (acquisition.Experiment.proj() & entry) and (not acquisition.Experiment.Subject & entry):
+            new_entries.append(entry)
+            logger.info(f"\tNew experiment subject: {entry}")
 
     acquisition.Experiment.Subject.insert(new_entries)

aeon/dj_pipeline/tracking.py

@@ -122,7 +122,7 @@ class SLEAPTracking(dj.Imported):
     """
 
     class PoseIdentity(dj.Part):
-        definition = """ 
+        definition = """
         -> master
         identity_idx:           smallint
         ---
@@ -210,7 +210,7 @@ def make(self, key):
 
         # get anchor part
         # ie the body_part with the prefix "anchor_" (there should only be one)
-        anchor_part = set(part for part in pose_data.part.unique() if part.startswith("anchor_"))
+        anchor_part = {part for part in pose_data.part.unique() if part.startswith("anchor_")}
         if len(anchor_part) != 1:
             raise ValueError(f"Anchor part not found or multiple anchor parts found: {anchor_part}")
         anchor_part = anchor_part.pop()

aeon/dj_pipeline/utils/streams_maker.py

@@ -149,7 +149,6 @@ def key_source(self):
             + Chunk(s) started after {device_type} install time & ended before {device_type} remove time
             + Chunk(s) started after {device_type} install time for {device_type} and not yet removed
             """
-
             return (
                 acquisition.Chunk * ExperimentDevice.join(ExperimentDevice.RemovalTime, left=True)
                 & "chunk_start >= {device_type_name}_install_time"