[DES-195] apply ruff format to drifted files

Four files drifted from `ruff format` between recent merges and were
failing `uv run ruff format --check packages/` on CI:
  - chat-adapter-shared: card_utils.py + test_card_utils.py
  - chat-adapter-state-memory: __init__.py + test_memory_state_adapter.py

Purely formatting; no semantic changes.

Author: tarasyarema

packages/chat-adapter-shared/src/chat_adapter_shared/card_utils.py

@@ -138,8 +138,7 @@ def _child_to_fallback_text(
         return "\n".join(
             t
             for t in (
-                _child_to_fallback_text(c, convert_text)
-                for c in _get(child, "children", []) or []
+                _child_to_fallback_text(c, convert_text) for c in _get(child, "children", []) or []
             )
             if t
         )

packages/chat-adapter-shared/tests/test_card_utils.py

@@ -181,10 +181,7 @@ def test_uses_double_asterisks_for_markdown_bold_format(self) -> None:
 
     def test_uses_double_line_breaks_when_specified(self) -> None:
         card = Card(title="Title", subtitle="Subtitle")
-        assert (
-            card_to_fallback_text(card, {"line_break": "\n\n"})
-            == "*Title*\n\nSubtitle"
-        )
+        assert card_to_fallback_text(card, {"line_break": "\n\n"}) == "*Title*\n\nSubtitle"
 
     def test_formats_text_children(self) -> None:
         card = Card(title="Card", children=[CardText("Some content")])
@@ -193,10 +190,12 @@ def test_formats_text_children(self) -> None:
     def test_formats_fields(self) -> None:
         card = Card(
             children=[
-                Fields([
-                    Field(label="Name", value="John"),
-                    Field(label="Age", value="30"),
-                ]),
+                Fields(
+                    [
+                        Field(label="Name", value="John"),
+                        Field(label="Age", value="30"),
+                    ]
+                ),
             ],
         )
         assert card_to_fallback_text(card) == "Name: John\nAge: 30"
@@ -208,10 +207,12 @@ def test_formats_fields_as_label_value_pairs(self) -> None:
     def test_excludes_actions_from_fallback_text(self) -> None:
         card = Card(
             children=[
-                Actions([
-                    Button(id="ok", label="OK"),
-                    Button(id="cancel", label="Cancel"),
-                ]),
+                Actions(
+                    [
+                        Button(id="ok", label="OK"),
+                        Button(id="cancel", label="Cancel"),
+                    ]
+                ),
             ],
         )
         assert card_to_fallback_text(card) == ""
@@ -243,14 +244,18 @@ def test_handles_complex_card_with_all_elements(self) -> None:
             children=[
                 CardText("Thank you for your purchase!"),
                 Divider(),
-                Fields([
-                    Field(label="Status", value="Processing"),
-                    Field(label="Total", value="$99.99"),
-                ]),
-                Actions([
-                    Button(id="view", label="View Order", style="primary"),
-                    Button(id="cancel", label="Cancel", style="danger"),
-                ]),
+                Fields(
+                    [
+                        Field(label="Status", value="Processing"),
+                        Field(label="Total", value="$99.99"),
+                    ]
+                ),
+                Actions(
+                    [
+                        Button(id="view", label="View Order", style="primary"),
+                        Button(id="cancel", label="Cancel", style="danger"),
+                    ]
+                ),
             ],
         )
 

packages/chat-adapter-state-memory/src/chat_adapter_state_memory/__init__.py

@@ -281,11 +281,7 @@ async def append_to_list(
         cached = self._cache.get(key)
         list_value: list[Any]
 
-        if (
-            cached is not None
-            and cached.expires_at is not None
-            and cached.expires_at <= _now_ms()
-        ):
+        if cached is not None and cached.expires_at is not None and cached.expires_at <= _now_ms():
             list_value = []
         elif cached is not None and isinstance(cached.value, list):
             list_value = cached.value
@@ -363,9 +359,7 @@ async def queue_depth(self, thread_id: str) -> int:
 
     def _ensure_connected(self) -> None:
         if not self._connected:
-            raise RuntimeError(
-                "MemoryStateAdapter is not connected. Call connect() first."
-            )
+            raise RuntimeError("MemoryStateAdapter is not connected. Call connect() first.")
 
     def _clean_expired_locks(self) -> None:
         now = _now_ms()

packages/chat-adapter-state-memory/tests/test_memory_state_adapter.py

@@ -73,11 +73,13 @@ async def test_should_not_release_a_lock_with_wrong_token(
         lock = await adapter.acquire_lock("thread1", 5000)
         assert lock is not None
 
-        await adapter.release_lock({
-            "thread_id": "thread1",
-            "token": "fake-token",
-            "expires_at": 0,
-        })
+        await adapter.release_lock(
+            {
+                "thread_id": "thread1",
+                "token": "fake-token",
+                "expires_at": 0,
+            }
+        )
 
         # Original lock should still be held
         lock2 = await adapter.acquire_lock("thread1", 5000)
@@ -86,9 +88,7 @@ async def test_should_not_release_a_lock_with_wrong_token(
         # Clean up
         await adapter.release_lock(lock)
 
-    async def test_should_allow_re_locking_after_expiry(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_allow_re_locking_after_expiry(self, adapter: MemoryStateAdapter) -> None:
         lock1 = await adapter.acquire_lock("thread1", 10)  # 10ms TTL
 
         await asyncio.sleep(0.020)  # 20ms
@@ -127,9 +127,7 @@ async def test_should_no_op_when_force_releasing_a_non_existent_lock(
         result = await adapter.force_release_lock("nonexistent")
         assert result is None
 
-    async def test_should_not_extend_an_expired_lock(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_not_extend_an_expired_lock(self, adapter: MemoryStateAdapter) -> None:
         lock = await adapter.acquire_lock("thread1", 10)
         assert lock is not None
 
@@ -152,26 +150,20 @@ async def test_should_set_a_value_when_key_does_not_exist(
         assert result is True
         assert await adapter.get("key1") == "value1"
 
-    async def test_should_not_overwrite_an_existing_key(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_not_overwrite_an_existing_key(self, adapter: MemoryStateAdapter) -> None:
         await adapter.set_if_not_exists("key1", "first")
         result = await adapter.set_if_not_exists("key1", "second")
         assert result is False
         assert await adapter.get("key1") == "first"
 
-    async def test_should_allow_setting_after_ttl_expiry(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_allow_setting_after_ttl_expiry(self, adapter: MemoryStateAdapter) -> None:
         await adapter.set_if_not_exists("key1", "first", 10)
         await asyncio.sleep(0.020)
         result = await adapter.set_if_not_exists("key1", "second")
         assert result is True
         assert await adapter.get("key1") == "second"
 
-    async def test_should_respect_ttl_on_the_new_value(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_respect_ttl_on_the_new_value(self, adapter: MemoryStateAdapter) -> None:
         await adapter.set_if_not_exists("key1", "value", 10)
         await asyncio.sleep(0.020)
         assert await adapter.get("key1") is None
@@ -183,9 +175,7 @@ async def test_should_respect_ttl_on_the_new_value(
 
 
 class TestAppendToListGetList:
-    async def test_should_append_and_retrieve_list_items(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_append_and_retrieve_list_items(self, adapter: MemoryStateAdapter) -> None:
         await adapter.append_to_list("list1", {"id": 1})
         await adapter.append_to_list("list1", {"id": 2})
 
@@ -228,18 +218,14 @@ async def test_should_refresh_ttl_on_subsequent_appends(
         result = await adapter.get_list("list1")
         assert result == [{"id": 1}, {"id": 2}]
 
-    async def test_should_keep_lists_isolated_by_key(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_keep_lists_isolated_by_key(self, adapter: MemoryStateAdapter) -> None:
         await adapter.append_to_list("list-a", "a")
         await adapter.append_to_list("list-b", "b")
 
         assert await adapter.get_list("list-a") == ["a"]
         assert await adapter.get_list("list-b") == ["b"]
 
-    async def test_should_start_fresh_after_expired_list(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_start_fresh_after_expired_list(self, adapter: MemoryStateAdapter) -> None:
         await adapter.append_to_list("list1", {"id": 1}, {"ttl_ms": 10})
         await asyncio.sleep(0.020)
 
@@ -353,9 +339,7 @@ async def test_should_handle_max_size_of_one_debounce_behavior(
         result = await adapter.dequeue("thread1")
         assert result["message"] == {"id": "m3"}
 
-    async def test_should_keep_queues_isolated_by_thread(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_keep_queues_isolated_by_thread(self, adapter: MemoryStateAdapter) -> None:
         await adapter.enqueue(
             "thread-a",
             {"message": {"id": "a1"}, "enqueued_at": 1000, "expires_at": 90000},
@@ -376,9 +360,7 @@ async def test_should_keep_queues_isolated_by_thread(
         rb = await adapter.dequeue("thread-b")
         assert rb["message"] == {"id": "b1"}
 
-    async def test_should_clear_queues_on_disconnect(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_clear_queues_on_disconnect(self, adapter: MemoryStateAdapter) -> None:
         await adapter.enqueue(
             "thread1",
             {"message": {"id": "m1"}, "enqueued_at": 1000, "expires_at": 90000},
@@ -403,9 +385,7 @@ async def test_should_throw_when_not_connected(self) -> None:
         with pytest.raises(RuntimeError, match="not connected"):
             await new_adapter.subscribe("test")
 
-    async def test_should_clear_state_on_disconnect(
-        self, adapter: MemoryStateAdapter
-    ) -> None:
+    async def test_should_clear_state_on_disconnect(self, adapter: MemoryStateAdapter) -> None:
         await adapter.subscribe("thread1")
         await adapter.acquire_lock("thread1", 5000)