style: apply ruff format

Apply `ruff format` to satisfy the CI format-check gate (ruff format --check).
Whitespace/layout only — no logic changes. Covers files from the connector
work and the temperature/context-window fixes.

Co-Authored-By: claude-flow <ruv@ruv.net>

Author: tom-shyftlabs

src/continuum/connectors/registry.py

@@ -18,9 +18,7 @@
 _REGISTRY: dict[str, BaseConnector[Any]] = {}
 
 
-def register_connector(
-    name: str, connector: BaseConnector[Any], *, replace: bool = False
-) -> None:
+def register_connector(name: str, connector: BaseConnector[Any], *, replace: bool = False) -> None:
     """Register a connector under ``name``.
 
     Raises ValueError if the name is already taken unless ``replace=True``.

src/continuum/llm/context_window.py

@@ -251,9 +251,7 @@ def _fetch_model_limits(
             for family, family_max in self.FAMILY_DEFAULTS.items():
                 if family in model_lower:
                     max_tokens = family_max
-                    logger.debug(
-                        f"Using {family}-family default limit for {model}: {max_tokens}"
-                    )
+                    logger.debug(f"Using {family}-family default limit for {model}: {max_tokens}")
                     break
 
         # 4. Conservative fallback

src/continuum/llm/providers/anthropic_provider.py

@@ -352,9 +352,7 @@ def stream(
             self._handle_exception(e, config.model)
             raise
 
-    async def _do_astream(
-        self, kwargs: dict[str, Any], model: str
-    ) -> AsyncIterator[StreamChunk]:
+    async def _do_astream(self, kwargs: dict[str, Any], model: str) -> AsyncIterator[StreamChunk]:
         async with self._async_client.messages.stream(**kwargs) as stream:
             async for text in stream.text_stream:
                 yield StreamChunk(content=text, is_finished=False)

src/continuum/session/providers/memory.py

@@ -192,9 +192,7 @@ async def get_session_metadata(self, session_id: str) -> SessionMetadata | None:
             meta.message_count = len(entry["messages"])
             return meta
 
-    async def update_session_metadata(
-        self, session_id: str, metadata: SessionMetadata
-    ) -> bool:
+    async def update_session_metadata(self, session_id: str, metadata: SessionMetadata) -> bool:
         with self._lock:
             entry = self._store.get(session_id)
             if entry is None:

tests/unit/test_connector_langfuse.py

@@ -45,7 +45,11 @@ def test_unconfigured_without_keys(self):
 class TestDescribeMasksSecrets:
     def test_keys_masked(self):
         c = LangfuseConnector(
-            _cfg(public_key="pk-publicsecret", secret_key="sk-supersecret", host="http://localhost:3000")
+            _cfg(
+                public_key="pk-publicsecret",
+                secret_key="sk-supersecret",
+                host="http://localhost:3000",
+            )
         )
         d = c.describe()
         assert d["name"] == "langfuse"

tests/unit/test_connector_redis.py

@@ -19,9 +19,7 @@ def test_localhost_is_local_docker(self):
         assert c.mode is ConnectionMode.LOCAL_DOCKER
 
     def test_ssl_is_cloud(self):
-        c = RedisConnector(
-            SessionConfig(enabled=True, redis_host="my.redis.cloud", redis_ssl=True)
-        )
+        c = RedisConnector(SessionConfig(enabled=True, redis_host="my.redis.cloud", redis_ssl=True))
         assert c.mode is ConnectionMode.CLOUD
 
     def test_remote_without_ssl_is_custom(self):

tests/unit/test_connector_temporal.py

@@ -42,7 +42,9 @@ def test_disabled_is_disabled(self):
 
 class TestConfigured:
     def test_configured_when_host_present(self):
-        assert TemporalConnector(TemporalConfig(enabled=True, host="localhost:7233")).is_configured()
+        assert TemporalConnector(
+            TemporalConfig(enabled=True, host="localhost:7233")
+        ).is_configured()
 
     def test_unconfigured_when_host_empty(self):
         assert not TemporalConnector(TemporalConfig(enabled=True, host="")).is_configured()
@@ -78,9 +80,7 @@ async def test_connect_wraps_errors(self, monkeypatch):
 
 class TestApingIsQuiet:
     async def test_aping_true_on_connect(self, monkeypatch):
-        monkeypatch.setattr(
-            "temporalio.client.Client.connect", AsyncMock(return_value=object())
-        )
+        monkeypatch.setattr("temporalio.client.Client.connect", AsyncMock(return_value=object()))
         c = TemporalConnector(TemporalConfig(enabled=True, host="localhost:7233"))
         assert await c.aping() is True
 

tests/unit/test_connectors_skeleton.py

@@ -23,7 +23,9 @@
 class _DummyConnector(BaseConnector[str]):
     name = "dummy"
 
-    def __init__(self, *, enabled=True, configured=True, reachable=True, mode=ConnectionMode.CUSTOM):
+    def __init__(
+        self, *, enabled=True, configured=True, reachable=True, mode=ConnectionMode.CUSTOM
+    ):
         self._enabled = enabled
         self._configured = configured
         self._reachable = reachable

tests/unit/test_session_midsession_fallback.py

@@ -51,7 +51,10 @@ async def test_degrades_to_memory_warns_once_no_per_request_errors(self, monkeyp
         )
         logspy, errspy = _spies(monkeypatch)
 
-        sc = SessionClient(session_config=SessionConfig(enabled=True, fallback_mode="degrade"), auto_initialize=False)
+        sc = SessionClient(
+            session_config=SessionConfig(enabled=True, fallback_mode="degrade"),
+            auto_initialize=False,
+        )
 
         results = []
         for _ in range(5):
@@ -75,7 +78,10 @@ async def test_roundtrip_works_after_degrade(self, monkeypatch):
         )
         _spies(monkeypatch)
 
-        sc = SessionClient(session_config=SessionConfig(enabled=True, fallback_mode="degrade"), auto_initialize=False)
+        sc = SessionClient(
+            session_config=SessionConfig(enabled=True, fallback_mode="degrade"),
+            auto_initialize=False,
+        )
 
         sid = await sc.get_or_create_session(user_id="shopper-2")  # triggers degrade
         await sc.add_message(sid, _msg("user", "hello"))
@@ -96,7 +102,10 @@ async def test_session_not_found_propagates_without_degrade(self, monkeypatch):
         )
         _spies(monkeypatch)
 
-        sc = SessionClient(session_config=SessionConfig(enabled=True, fallback_mode="degrade"), auto_initialize=False)
+        sc = SessionClient(
+            session_config=SessionConfig(enabled=True, fallback_mode="degrade"),
+            auto_initialize=False,
+        )
 
         with pytest.raises(SessionNotFoundError):
             await sc.get_conversation_history("x")
@@ -128,7 +137,9 @@ async def test_session_store_down_skips_quietly(self, monkeypatch):
         # Injected provider → never degrades; the SessionConnectionError surfaces
         # into _store_in_memory exactly as it does in fail-mode with Redis down.
         sc = SessionClient(
-            session_config=SessionConfig(enabled=True, fallback_mode="degrade"), provider=provider, auto_initialize=False
+            session_config=SessionConfig(enabled=True, fallback_mode="degrade"),
+            provider=provider,
+            auto_initialize=False,
         )
 
         await sc._store_in_memory(