Use bleeding-edge ruff/mypy, enforce ruff format, fix formatting on all files

Author: janbjorge

.dmypy.json

@@ -0,0 +1 @@
+{"pid": 20917, "connection_name": "/var/folders/pr/r4bw9ms530v1y0b9_b0678m80000gn/T/tmphvhuxtfg/dmypy.sock"}

.github/workflows/ci.yml

@@ -24,6 +24,9 @@ jobs:
       - name: Install dependencies
         run: uv sync --extra dev
 
+      - name: ruff format
+        run: uv run ruff format --check .
+
       - name: ruff check
         run: uv run ruff check .
 

.github/workflows/release.yml

@@ -22,6 +22,9 @@ jobs:
       - name: Install dependencies
         run: uv sync --extra dev
 
+      - name: ruff format
+        run: uv run ruff format --check .
+
       - name: ruff check
         run: uv run ruff check .
 

jqueue/__init__.py

@@ -56,6 +56,7 @@ async def write(content, if_match=None) -> str
   core/     — business logic (DirectQueue, BrokerQueue, GroupCommitLoop)
   adapters/ — concrete storage implementations
 """
+
 from __future__ import annotations
 
 from jqueue.adapters.storage.filesystem import LocalFileSystemStorage

jqueue/adapters/storage/filesystem.py

@@ -22,6 +22,7 @@
 
 POSIX-only (Linux, macOS). Not compatible with NFS or distributed filesystems.
 """
+
 from __future__ import annotations
 
 import asyncio

jqueue/adapters/storage/memory.py

@@ -11,6 +11,7 @@
 Zero external dependencies. Safe for multiple concurrent coroutines in a
 single event loop. NOT safe across processes or threads.
 """
+
 from __future__ import annotations
 
 import asyncio

jqueue/core/broker.py

@@ -23,6 +23,7 @@
 and dequeue call that arrives is buffered and committed in the *next* write —
 collapsing N concurrent writes down to O(1) storage round-trips.
 """
+
 from __future__ import annotations
 
 import dataclasses

jqueue/core/codec.py

@@ -24,6 +24,7 @@
   ]
 }
 """
+
 from __future__ import annotations
 
 from jqueue.domain.models import QueueState

jqueue/core/direct.py

@@ -15,6 +15,7 @@
 with linear back-off (10ms × attempt). Raises CASConflictError if all retries
 are exhausted.
 """
+
 from __future__ import annotations
 
 import asyncio
@@ -111,9 +112,7 @@ def _fn(state: QueueState) -> QueueState:
             job = state.find(job_id)
             if job is None:
                 raise JobNotFoundError(job_id)
-            return state.with_job_replaced(
-                job.with_heartbeat(datetime.now(UTC))
-            )
+            return state.with_job_replaced(job.with_heartbeat(datetime.now(UTC)))
 
         await self._mutate(_fn)
 

jqueue/core/group_commit.py

@@ -23,6 +23,7 @@
 If one mutation in a batch raises (e.g., JobNotFoundError), that future gets
 the exception but the other mutations in the batch still commit normally.
 """
+
 from __future__ import annotations
 
 import asyncio
@@ -168,9 +169,7 @@ def _fn(state: QueueState) -> QueueState:
             job = state.find(job_id)
             if job is None:
                 raise JobNotFoundError(job_id)
-            return state.with_job_replaced(
-                job.with_heartbeat(datetime.now(UTC))
-            )
+            return state.with_job_replaced(job.with_heartbeat(datetime.now(UTC)))
 
         await self._submit(_fn)