temporalio.contrib.langgraph.LangGraphPlugin

class documentation

class LangGraphPlugin(SimplePlugin): (source)

Constructor: LangGraphPlugin(graphs, entrypoints, tasks, activity_options, default_activity_options)

View In Hierarchy

LangGraph plugin for Temporal SDK.

Warning

This package is experimental and may change in future versions. Use with caution in production environments.

This plugin runs LangGraph nodes and tasks as Temporal Activities, giving your AI agent workflows durable execution, automatic retries, and timeouts. It supports both the LangGraph Graph API (StateGraph) and Functional API (@entrypoint / @task).

Method __init__ Initialize the LangGraph plugin with graphs, entrypoints, and tasks.
Method execute Prepare a node or task to execute as an activity or inline in the workflow.
Instance Variable activities Undocumented

Inherited from SimplePlugin:

Method configure_client See base class.
Method configure_replayer See base class.
Method configure_worker See base class.
Async Method connect_service_client See base class.
Method name See base class.
Async Method run_replayer See base class.
Async Method run_worker See base class.
Instance Variable data_converter Undocumented
Instance Variable interceptors Undocumented
Instance Variable nexus_service_handlers Undocumented
Instance Variable run_context Undocumented
Instance Variable workflow_failure_exception_types Undocumented
Instance Variable workflow_runner Undocumented
Instance Variable workflows Undocumented
Instance Variable _name Undocumented
def __init__(self, graphs: dict[str, StateGraph[Any, Any, Any, Any]] | None = None, entrypoints: dict[str, Pregel[Any, Any, Any, Any]] | None = None, tasks: list | None = None, activity_options: dict[str, dict[str, Any]] | None = None, default_activity_options: dict[str, Any] | None = None): (source)
overrides temporalio.plugin.SimplePlugin.__init__

Initialize the LangGraph plugin with graphs, entrypoints, and tasks.

def execute(self, activity_name: str, func: Callable, kwargs: dict[str, Any] | None = None) -> Callable: (source)

Prepare a node or task to execute as an activity or inline in the workflow.

activities: list = (source)
overrides temporalio.plugin.SimplePlugin.activities

Undocumented