style: Apply ruff formatting

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: dimitri-yatsenko

.secrets/database.password

@@ -0,0 +1 @@
+tutorial

.secrets/database.user

@@ -0,0 +1 @@
+root

datajoint.json

@@ -0,0 +1,8 @@
+{
+  "database": {
+    "host": "127.0.0.1",
+    "port": 3306
+  },
+  "safemode": false,
+  "loglevel": "WARNING"
+}

src/datajoint/codecs.py

@@ -112,7 +112,7 @@ def __init_subclass__(cls, *, register: bool = True, **kwargs):
             existing = _codec_registry[cls.name]
             if type(existing) is not cls:
                 raise DataJointError(
-                    f"Codec <{cls.name}> already registered by " f"{type(existing).__module__}.{type(existing).__name__}"
+                    f"Codec <{cls.name}> already registered by {type(existing).__module__}.{type(existing).__name__}"
                 )
             return  # Same class, idempotent
 
@@ -301,7 +301,7 @@ def get_codec(name: str) -> Codec:
         return _codec_registry[type_name]
 
     raise DataJointError(
-        f"Unknown codec: <{type_name}>. " f"Ensure the codec is defined (inherit from dj.Codec with name='{type_name}')."
+        f"Unknown codec: <{type_name}>. Ensure the codec is defined (inherit from dj.Codec with name='{type_name}')."
     )
 
 
@@ -499,7 +499,7 @@ def lookup_codec(codec_spec: str) -> tuple[Codec, str | None]:
     if is_codec_registered(type_name):
         return get_codec(type_name), store_name
 
-    raise DataJointError(f"Codec <{type_name}> is not registered. " "Define a Codec subclass with name='{type_name}'.")
+    raise DataJointError(f"Codec <{type_name}> is not registered. Define a Codec subclass with name='{{type_name}}'.")
 
 
 # =============================================================================

src/datajoint/content_registry.py

@@ -151,7 +151,7 @@ def get_content(content_hash: str, store_name: str | None = None) -> bytes:
     # Verify hash (optional but recommended for integrity)
     actual_hash = compute_content_hash(data)
     if actual_hash != content_hash:
-        raise DataJointError(f"Content hash mismatch: expected {content_hash[:16]}..., " f"got {actual_hash[:16]}...")
+        raise DataJointError(f"Content hash mismatch: expected {content_hash[:16]}..., got {actual_hash[:16]}...")
 
     return data
 

src/datajoint/heading.py

@@ -41,17 +41,17 @@ def name(self) -> str:
 
     def get_dtype(self, is_external: bool) -> str:
         raise DataJointError(
-            f"Codec <{self._codec_name}> is not registered. " f"Define a Codec subclass with name='{self._codec_name}'."
+            f"Codec <{self._codec_name}> is not registered. Define a Codec subclass with name='{self._codec_name}'."
         )
 
     def encode(self, value, *, key=None, store_name=None):
         raise DataJointError(
-            f"Codec <{self._codec_name}> is not registered. " f"Define a Codec subclass with name='{self._codec_name}'."
+            f"Codec <{self._codec_name}> is not registered. Define a Codec subclass with name='{self._codec_name}'."
         )
 
     def decode(self, stored, *, key=None):
         raise DataJointError(
-            f"Codec <{self._codec_name}> is not registered. " f"Define a Codec subclass with name='{self._codec_name}'."
+            f"Codec <{self._codec_name}> is not registered. Define a Codec subclass with name='{self._codec_name}'."
         )
 
 

src/datajoint/jobs.py

@@ -145,7 +145,7 @@ def _generate_definition(self) -> str:
 
         if not pk_attrs:
             raise DataJointError(
-                f"Cannot create jobs table for {self._target.full_table_name}: " "no FK-derived primary key attributes found."
+                f"Cannot create jobs table for {self._target.full_table_name}: no FK-derived primary key attributes found."
             )
 
         pk_lines = "\n    ".join(f"{name} : {dtype}" for name, dtype in pk_attrs)

src/datajoint/settings.py

@@ -389,7 +389,7 @@ def get_store_spec(self, store: str) -> dict[str, Any]:
         if protocol not in supported_protocols:
             raise DataJointError(
                 f'Missing or invalid protocol in config.stores["{store}"]. '
-                f'Supported protocols: {", ".join(supported_protocols)}'
+                f"Supported protocols: {', '.join(supported_protocols)}"
             )
 
         # Define required and allowed keys by protocol
@@ -479,7 +479,7 @@ def get_object_storage_spec(self) -> dict[str, Any]:
         supported_protocols = ("file", "s3", "gcs", "azure")
         if protocol not in supported_protocols:
             raise DataJointError(
-                f"Invalid object_storage.protocol: {protocol}. " f'Supported protocols: {", ".join(supported_protocols)}'
+                f"Invalid object_storage.protocol: {protocol}. Supported protocols: {', '.join(supported_protocols)}"
             )
 
         # Build spec dict
@@ -555,8 +555,7 @@ def get_object_store_spec(self, store_name: str | None = None) -> dict[str, Any]
         supported_protocols = ("file", "s3", "gcs", "azure")
         if protocol not in supported_protocols:
             raise DataJointError(
-                f"Invalid protocol for store '{store_name}': {protocol}. "
-                f'Supported protocols: {", ".join(supported_protocols)}'
+                f"Invalid protocol for store '{store_name}': {protocol}. Supported protocols: {', '.join(supported_protocols)}"
             )
 
         # Use project_name from default config if not specified in store

src/datajoint/table.py

@@ -963,8 +963,7 @@ def cascade(table):
                     transaction = False
                 else:
                     raise DataJointError(
-                        "Delete cannot use a transaction within an ongoing transaction. "
-                        "Set transaction=False or prompt=False."
+                        "Delete cannot use a transaction within an ongoing transaction. Set transaction=False or prompt=False."
                     )
 
         # Cascading delete

src/datajoint/user_tables.py

@@ -252,9 +252,7 @@ def drop(self, part_integrity: str = "enforce"):
         if part_integrity == "ignore":
             super().drop()
         elif part_integrity == "enforce":
-            raise DataJointError(
-                "Cannot drop a Part directly. Drop master instead, " "or use part_integrity='ignore' to force."
-            )
+            raise DataJointError("Cannot drop a Part directly. Drop master instead, or use part_integrity='ignore' to force.")
         else:
             raise ValueError(f"part_integrity for drop must be 'enforce' or 'ignore', got {part_integrity!r}")