chore: Fix ruff formatting and lint errors

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: GoodbyePlanet

.github/workflows/ci.yml

@@ -2,22 +2,19 @@ name: CI
 
 on:
   push:
-    branches: [main]
+    branches: [ main ]
   pull_request:
-    branches: [main]
+    branches: [ main ]
 
 jobs:
   lint:
     name: Lint
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4
-
       - uses: astral-sh/setup-uv@v5
-
       - name: Check formatting
         run: uvx ruff format --check .
-
       - name: Lint
         run: uvx ruff check .
 
@@ -26,13 +23,10 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v4
-
       - uses: astral-sh/setup-uv@v5
         with:
           enable-cache: true
-
       - name: Install dependencies
         run: uv sync --frozen --all-groups
-
       - name: Run tests
-        run: uv run pytest --tb=short -q
+        run: uv run pytest --tb=short -q

server/config.py

@@ -18,8 +18,8 @@ def __init__(
     ) -> None:
         self.name = name
         self.github_repo = github_repo  # e.g. "myorg/catalog-service"
-        self.github_ref = github_ref    # branch, tag, or commit SHA
-        self.root = root                # optional path prefix within the repo
+        self.github_ref = github_ref  # branch, tag, or commit SHA
+        self.root = root  # optional path prefix within the repo
         self.exclude = exclude
 
 
@@ -34,7 +34,9 @@ class Settings(BaseSettings):
 
     qdrant_url: str = Field(default="http://localhost:6333", alias="QDRANT_URL")
     qdrant_collection: str = Field(default="code_symbols", alias="QDRANT_COLLECTION")
-    qdrant_commits_collection: str = Field(default="git_commits", alias="QDRANT_COMMITS_COLLECTION")
+    qdrant_commits_collection: str = Field(
+        default="git_commits", alias="QDRANT_COMMITS_COLLECTION"
+    )
     git_history_max_commits: int = Field(default=500, alias="GIT_HISTORY_MAX_COMMITS")
 
     mcp_transport: Literal["streamable-http", "sse", "stdio"] = Field(

server/embeddings/bm25.py

@@ -31,7 +31,9 @@ async def embed_query(self, text: str) -> SparseVector:
         [embedding] = await loop.run_in_executor(
             None, lambda: list(self._model.query_embed(prepared))
         )
-        return SparseVector(indices=embedding.indices.tolist(), values=embedding.values.tolist())
+        return SparseVector(
+            indices=embedding.indices.tolist(), values=embedding.values.tolist()
+        )
 
 
 def get_sparse_embedding_provider() -> BM25SparseProvider:

server/embeddings/code_tokenizer.py

@@ -9,8 +9,8 @@ def split_code_identifiers(text: str) -> str:
     Both the original tokens and their subword splits are returned so BM25
     matches exact identifiers (PlaceOrderRequest) AND partial queries (place order).
     """
-    expanded = re.sub(r'([a-z0-9])([A-Z])', r'\1 \2', text)
-    expanded = re.sub(r'([A-Z]+)([A-Z][a-z])', r'\1 \2', expanded)
-    expanded = expanded.replace('_', ' ')
-    expanded = expanded.replace('-', ' ')
+    expanded = re.sub(r"([a-z0-9])([A-Z])", r"\1 \2", text)
+    expanded = re.sub(r"([A-Z]+)([A-Z][a-z])", r"\1 \2", expanded)
+    expanded = expanded.replace("_", " ")
+    expanded = expanded.replace("-", " ")
     return text + "\n" + expanded

server/indexer/git_history.py

@@ -10,7 +10,11 @@
 from server.config import settings
 from server.embeddings.base import EmbeddingProvider
 from server.embeddings.jina import get_embedding_provider
-from server.indexer.github_source import GitHubCommit, fetch_commits_with_diffs, list_commits
+from server.indexer.github_source import (
+    GitHubCommit,
+    fetch_commits_with_diffs,
+    list_commits,
+)
 from server.indexer.pipeline import ProgressEvent
 from server.store.commit_store import CommitStore
 
@@ -78,25 +82,34 @@ async def index_service(
 
         async with httpx.AsyncClient() as http_client:
             commits = await list_commits(
-                settings.github_token, svc.github_repo, svc.github_ref,
-                root=svc.root, max_commits=settings.git_history_max_commits,
+                settings.github_token,
+                svc.github_repo,
+                svc.github_ref,
+                root=svc.root,
+                max_commits=settings.git_history_max_commits,
                 client=http_client,
             )
 
         if progress_callback:
-            await progress_callback(ProgressEvent(
-                phase="discovery",
-                current=len(commits),
-                total=len(commits),
-                percentage=100.0,
-                service=service_name,
-            ))
+            await progress_callback(
+                ProgressEvent(
+                    phase="discovery",
+                    current=len(commits),
+                    total=len(commits),
+                    percentage=100.0,
+                    service=service_name,
+                )
+            )
 
         existing_shas = set() if force else await self._store.get_indexed_shas(svc.name)
         new_commits = [c for c in commits if c.sha not in existing_shas]
         skipped = len(commits) - len(new_commits)
 
-        shas_without_diffs = set(await self._store.get_commits_without_diffs(svc.name)) if not force else set()
+        shas_without_diffs = (
+            set(await self._store.get_commits_without_diffs(svc.name))
+            if not force
+            else set()
+        )
         commits_needing_diffs = [c for c in commits if c.sha in shas_without_diffs]
 
         if not new_commits and not commits_needing_diffs:
@@ -105,41 +118,55 @@ async def index_service(
         diff_updated = 0
 
         if new_commits:
-            logger.info("Fetching diffs for %d new commits in %s", len(new_commits), service_name)
+            logger.info(
+                "Fetching diffs for %d new commits in %s",
+                len(new_commits),
+                service_name,
+            )
             new_commits = await fetch_commits_with_diffs(
                 settings.github_token, svc.github_repo, new_commits
             )
             texts = [_build_embedding_text(c, svc.name) for c in new_commits]
             try:
                 vectors = await self._embedder.embed_batch(texts)
             except Exception as exc:
-                logger.error("Embedding failed for %s git history: %s", service_name, exc)
+                logger.error(
+                    "Embedding failed for %s git history: %s", service_name, exc
+                )
                 return {"error": 1, "new": 0, "skipped": skipped, "diff_updated": 0}
 
             if progress_callback:
-                await progress_callback(ProgressEvent(
-                    phase="embedding",
-                    current=len(new_commits),
-                    total=len(new_commits),
-                    percentage=100.0,
-                    service=service_name,
-                ))
+                await progress_callback(
+                    ProgressEvent(
+                        phase="embedding",
+                        current=len(new_commits),
+                        total=len(new_commits),
+                        percentage=100.0,
+                        service=service_name,
+                    )
+                )
 
             payloads = [_commit_to_payload(c, svc.name) for c in new_commits]
             await self._store.upsert_commits(svc.name, payloads, vectors)
             logger.info("Indexed %d new commits for %s", len(new_commits), service_name)
 
             if progress_callback:
-                await progress_callback(ProgressEvent(
-                    phase="upserting",
-                    current=len(new_commits),
-                    total=len(new_commits),
-                    percentage=100.0,
-                    service=service_name,
-                ))
+                await progress_callback(
+                    ProgressEvent(
+                        phase="upserting",
+                        current=len(new_commits),
+                        total=len(new_commits),
+                        percentage=100.0,
+                        service=service_name,
+                    )
+                )
 
         if commits_needing_diffs:
-            logger.info("Fetching diffs for %d existing commits in %s", len(commits_needing_diffs), service_name)
+            logger.info(
+                "Fetching diffs for %d existing commits in %s",
+                len(commits_needing_diffs),
+                service_name,
+            )
             commits_needing_diffs = await fetch_commits_with_diffs(
                 settings.github_token, svc.github_repo, commits_needing_diffs
             )
@@ -148,15 +175,21 @@ async def index_service(
             diff_updated = len(commits_needing_diffs)
 
             if progress_callback:
-                await progress_callback(ProgressEvent(
-                    phase="upserting",
-                    current=diff_updated,
-                    total=diff_updated,
-                    percentage=100.0,
-                    service=service_name,
-                ))
-
-        return {"new": len(new_commits), "skipped": skipped, "diff_updated": diff_updated}
+                await progress_callback(
+                    ProgressEvent(
+                        phase="upserting",
+                        current=diff_updated,
+                        total=diff_updated,
+                        percentage=100.0,
+                        service=service_name,
+                    )
+                )
+
+        return {
+            "new": len(new_commits),
+            "skipped": skipped,
+            "diff_updated": diff_updated,
+        }
 
     async def index_all(
         self,
@@ -167,5 +200,7 @@ async def index_all(
         results: dict[str, Any] = {}
         for svc in services:
             logger.info("Indexing git history for: %s", svc.name)
-            results[svc.name] = await self.index_service(svc.name, force=force, progress_callback=progress_callback)
+            results[svc.name] = await self.index_service(
+                svc.name, force=force, progress_callback=progress_callback
+            )
         return results