Ruff

Author: dicksontsai

src/claude_code_sdk/__init__.py

@@ -1,6 +1,5 @@
 """Claude SDK for Python."""
 
-
 from ._errors import (
     ClaudeSDKError,
     CLIConnectionError,

src/claude_code_sdk/_internal/client.py

@@ -40,9 +40,7 @@ async def process_query(
             chosen_transport = transport
         else:
             chosen_transport = SubprocessCLITransport(
-            prompt=prompt,
-            options=options,
-            close_stdin_after_prompt=True
+            prompt=prompt, options=options, close_stdin_after_prompt=True
         )
 
         try:

src/claude_code_sdk/_internal/transport/subprocess_cli.py

@@ -171,6 +171,7 @@ async def connect(self) -> None:
                     self._stdin_stream = TextSendStream(self._process.stdin)
                     # Start streaming messages to stdin in background
                     import asyncio
+
                     asyncio.create_task(self._stream_to_stdin())
             else:
                 # String mode: close stdin immediately (backward compatible)
@@ -224,7 +225,7 @@ async def send_request(self, messages: list[Any], options: dict[str, Any]) -> No
                     "type": "user",
                     "message": {"role": "user", "content": str(message)},
                     "parent_tool_use_id": None,
-                    "session_id": options.get("session_id", "default")
+                    "session_id": options.get("session_id", "default"),
                 }
 
             await self._stdin_stream.send(json.dumps(message) + "\n")
@@ -372,7 +373,9 @@ def is_connected(self) -> bool:
     async def interrupt(self) -> None:
         """Send interrupt control request (only works in streaming mode)."""
         if not self._is_streaming:
-            raise CLIConnectionError("Interrupt requires streaming mode (AsyncIterable prompt)")
+            raise CLIConnectionError(
+                "Interrupt requires streaming mode (AsyncIterable prompt)"
+            )
 
         if not self._stdin_stream:
             raise CLIConnectionError("Not connected or stdin not available")
@@ -392,7 +395,7 @@ async def _send_control_request(self, request: dict[str, Any]) -> dict[str, Any]
         control_request = {
             "type": "control_request",
             "request_id": request_id,
-            "request": request
+            "request": request,
         }
 
         # Send request
@@ -407,7 +410,9 @@ async def _send_control_request(self, request: dict[str, Any]) -> dict[str, Any]
                 response = self._pending_control_responses.pop(request_id)
 
                 if response.get("subtype") == "error":
-                    raise CLIConnectionError(f"Control request failed: {response.get('error')}")
+                    raise CLIConnectionError(
+                        f"Control request failed: {response.get('error')}"
+                    )
 
                 return response
         except TimeoutError:

tests/test_streaming_client.py

@@ -389,7 +389,8 @@ def _create_test_script(
         if response is None:
             response = '{"type": "result", "subtype": "success", "duration_ms": 100, "duration_api_ms": 50, "is_error": false, "num_turns": 1, "session_id": "test", "total_cost_usd": 0.001}'
 
-        script_content = textwrap.dedent("""
+        script_content = textwrap.dedent(
+            """
             #!/usr/bin/env python3
             import sys
             import json
@@ -416,7 +417,8 @@ def _create_test_script(
         )
 
         if expected_messages is not None:
-            script_content += textwrap.dedent(f"""
+            script_content += textwrap.dedent(
+                f"""
                 # Verify we got the expected messages
                 assert len(stdin_messages) == {len(expected_messages)}
                 """,
@@ -425,12 +427,14 @@ def _create_test_script(
                 script_content += f'''assert '"{msg}"' in stdin_messages[{i}]\n'''
 
         if should_error:
-            script_content += textwrap.dedent("""
+            script_content += textwrap.dedent(
+                """
                 sys.exit(1)
                 """,
             )
         else:
-            script_content += textwrap.dedent(f"""
+            script_content += textwrap.dedent(
+                f"""
                 # Output response
                 print('{response}')
                 """,