fmt

langchain-ai · Jun 27, 2024 · 30759de · 30759de
1 parent 7a532f1
commit 30759de
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/libs/sdk-py/langgraph_sdk/client.py b/libs/sdk-py/langgraph_sdk/client.py
@@ -439,7 +439,8 @@ def stream(
         interrupt_after: Optional[list[str]] = None,
         feedback_keys: Optional[list[str]] = None,
         multitask_strategy: Optional[MultitaskStrategy] = None,
-    ) -> AsyncIterator[StreamPart]: ...
+    ) -> AsyncIterator[StreamPart]:
+        ...
 
     @overload
     def stream(
@@ -454,7 +455,8 @@ def stream(
         interrupt_before: Optional[list[str]] = None,
         interrupt_after: Optional[list[str]] = None,
         feedback_keys: Optional[list[str]] = None,
-    ) -> AsyncIterator[StreamPart]: ...
+    ) -> AsyncIterator[StreamPart]:
+        ...
 
     def stream(
         self,
@@ -507,7 +509,8 @@ async def create(
         interrupt_before: Optional[list[str]] = None,
         interrupt_after: Optional[list[str]] = None,
         webhook: Optional[str] = None,
-    ) -> Run: ...
+    ) -> Run:
+        ...
 
     @overload
     async def create(
@@ -523,7 +526,8 @@ async def create(
         interrupt_after: Optional[list[str]] = None,
         webhook: Optional[str] = None,
         multitask_strategy: Optional[MultitaskStrategy] = None,
-    ) -> Run: ...
+    ) -> Run:
+        ...
 
     async def create(
         self,
@@ -570,7 +574,8 @@ async def wait(
         interrupt_before: Optional[list[str]] = None,
         interrupt_after: Optional[list[str]] = None,
         multitask_strategy: Optional[MultitaskStrategy] = None,
-    ) -> Union[list[dict], dict[str, Any]]: ...
+    ) -> Union[list[dict], dict[str, Any]]:
+        ...
 
     @overload
     async def wait(
@@ -583,7 +588,8 @@ async def wait(
         config: Optional[Config] = None,
         interrupt_before: Optional[list[str]] = None,
         interrupt_after: Optional[list[str]] = None,
-    ) -> Union[list[dict], dict[str, Any]]: ...
+    ) -> Union[list[dict], dict[str, Any]]:
+        ...
 
     async def wait(
         self,