style: ruff autofix (auto)

Author: autofix-ci[bot]

src/agent.py

@@ -112,6 +112,7 @@ def _stream_error_chunk(message: str, response_id: str | None = None) -> bytes:
         payload["response_id"] = response_id
     return (json.dumps(payload) + "\n").encode("utf-8")
 
+
 async def get_user_conversations(user_id: str):
     """Get conversation metadata for a user from persistent storage."""
     return await conversation_persistence.get_user_conversations(user_id)
@@ -163,9 +164,7 @@ async def store_conversation_thread(user_id: str, response_id: str, conversation
         content = first_user_msg.get("content", "")
         title = content[:50] + "..." if len(content) > 50 else content
 
-    user_assistant_messages = [
-        msg for msg in messages if msg.get("role") in ["user", "assistant"]
-    ]
+    user_assistant_messages = [msg for msg in messages if msg.get("role") in ["user", "assistant"]]
     metadata_only = {
         "response_id": response_id,
         "title": title,

src/services/chat_service.py

@@ -843,9 +843,7 @@ async def get_langflow_history(self, user_id: str):
                 ]
 
             if response_id in listed_ids:
-                existing = next(
-                    c for c in all_conversations if c["response_id"] == response_id
-                )
+                existing = next(c for c in all_conversations if c["response_id"] == response_id)
                 if len(messages) > len(existing.get("messages") or []):
                     existing["messages"] = messages
                     existing["total_messages"] = len(messages)
@@ -864,9 +862,7 @@ async def get_langflow_history(self, user_id: str):
                 else "New Chat"
             )
             created_at = metadata.get("created_at") or conversation_state.get("created_at")
-            last_activity = metadata.get("last_activity") or conversation_state.get(
-                "last_activity"
-            )
+            last_activity = metadata.get("last_activity") or conversation_state.get("last_activity")
             all_conversations.append(
                 {
                     "response_id": response_id,

tests/unit/test_langflow_stream_provider_errors.py

@@ -206,9 +206,7 @@ async def raise_provider_error(*_args, **_kwargs) -> AsyncIterator[bytes]:
 
 
 @pytest.mark.asyncio
-async def test_langflow_follow_up_after_error_reuses_store_id(
-    monkeypatch, store_in_memory
-):
+async def test_langflow_follow_up_after_error_reuses_store_id(monkeypatch, store_in_memory):
     """Retrying in the same chat must not create a second sidebar conversation."""
     provider_message = "Rate limit exceeded for watsonx.ai."
     stream_calls: list[dict] = []
@@ -263,9 +261,7 @@ async def raise_provider_error(*_args, **kwargs) -> AsyncIterator[bytes]:
 
 
 @pytest.mark.asyncio
-async def test_langflow_follow_up_ignores_broken_previous_response_id(
-    monkeypatch, store_in_memory
-):
+async def test_langflow_follow_up_ignores_broken_previous_response_id(monkeypatch, store_in_memory):
     """Even if the client still sends a failed Langflow session id, do not chain it."""
     provider_message = "Invalid API key for Anthropic. Check your credentials."
     stream_calls: list[dict] = []