From 7a532f18f1a21ff291473382c86c8b4a1e9c52ed Mon Sep 17 00:00:00 2001 From: isaac hershenson Date: Thu, 27 Jun 2024 13:20:39 -0700 Subject: [PATCH] fmt --- libs/sdk-py/langgraph_sdk/client.py | 18 ++++++------------ libs/sdk-py/langgraph_sdk/schema.py | 5 ++--- 2 files changed, 8 insertions(+), 15 deletions(-) diff --git a/libs/sdk-py/langgraph_sdk/client.py b/libs/sdk-py/langgraph_sdk/client.py index 12e5febb5..98396c5a0 100644 --- a/libs/sdk-py/langgraph_sdk/client.py +++ b/libs/sdk-py/langgraph_sdk/client.py @@ -439,8 +439,7 @@ 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( @@ -455,8 +454,7 @@ 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, @@ -509,8 +507,7 @@ 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( @@ -526,8 +523,7 @@ async def create( interrupt_after: Optional[list[str]] = None, webhook: Optional[str] = None, multitask_strategy: Optional[MultitaskStrategy] = None, - ) -> Run: - ... + ) -> Run: ... async def create( self, @@ -574,8 +570,7 @@ 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( @@ -588,8 +583,7 @@ 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, diff --git a/libs/sdk-py/langgraph_sdk/schema.py b/libs/sdk-py/langgraph_sdk/schema.py index c06e8103d..e40fc71cd 100644 --- a/libs/sdk-py/langgraph_sdk/schema.py +++ b/libs/sdk-py/langgraph_sdk/schema.py @@ -110,9 +110,8 @@ class Run(TypedDict): multitask_strategy: MultitaskStrategy """Strategy to handle concurrent runs on the same thread.""" -class Cron(TypedDict): - """Cron model.""" +class Cron(TypedDict): cron_id: str """The ID of the cron.""" thread_id: Optional[str] @@ -126,4 +125,4 @@ class Cron(TypedDict): updated_at: datetime """The last time the cron was updated.""" payload: dict - """The run payload to use for creating new run.""" \ No newline at end of file + """The run payload to use for creating new run."""