Lint

libs/langgraph/langgraph/pregel/algo.py

@@ -113,7 +113,7 @@ class Call:
     func: Callable
     input: Any
     retry: Optional[RetryPolicy]
-    callbacks: Optional[Callbacks]
+    callbacks: Callbacks
 
     def __init__(
         self,
@@ -121,7 +121,7 @@ class Call:
         input: Any,
         *,
         retry: Optional[RetryPolicy],
-        callbacks: Optional[Callbacks],
+        callbacks: Callbacks,
     ) -> None:
         self.func = func
         self.input = input

libs/langgraph/langgraph/pregel/runner.py

@@ -150,7 +150,7 @@ class PregelRunner:
             input: Any,
             *,
             retry: Optional[RetryPolicy] = None,
-            callbacks: Optional[Callbacks] = None,
+            callbacks: Callbacks = None,
         ) -> concurrent.futures.Future[Any]:
             (fut,) = writer(
                 task,
@@ -342,7 +342,7 @@ class PregelRunner:
             input: Any,
             *,
             retry: Optional[RetryPolicy] = None,
-            callbacks: Optional[Callbacks] = None,
+            callbacks: Callbacks = None,
         ) -> Union[asyncio.Future[Any], concurrent.futures.Future[Any]]:
             (fut,) = writer(
                 task,

libs/langgraph/langgraph/utils/config.py

@@ -132,7 +132,7 @@ def merge_configs(*configs: Optional[RunnableConfig]) -> RunnableConfig:
 def patch_config(
     config: Optional[RunnableConfig],
     *,
-    callbacks: Optional[Callbacks] = None,
+    callbacks: Callbacks = None,
     recursion_limit: Optional[int] = None,
     max_concurrency: Optional[int] = None,
     run_name: Optional[str] = None,