temporalio.contrib.langgraph._interceptor.LangGraphInterceptor

class documentation

class LangGraphInterceptor(Interceptor): (source)

Interceptor that registers a workflow's graphs and entrypoints for the run.

Method	`__init__`	Initialize with the graphs and entrypoints to scope to each workflow run.
Method	`workflow_interceptor_class`	Return the inbound interceptor class used to scope graphs per run.
Instance Variable	`_entrypoints`	Undocumented
Instance Variable	`_graphs`	Undocumented

Inherited from Interceptor:

Method	`intercept_activity`	Method called for intercepting an activity.
Method	`intercept_nexus_operation`	Method called for intercepting a Nexus operation.

def __init__(self, graphs: dict[str, StateGraph[Any, Any, Any, Any]], entrypoints: dict[str, Pregel[Any, Any, Any, Any]]): (source) ¶

Initialize with the graphs and entrypoints to scope to each workflow run.

def workflow_interceptor_class(self, input: WorkflowInterceptorClassInput) -> type[WorkflowInboundInterceptor]: (source) ¶

overrides temporalio.worker.Interceptor.workflow_interceptor_class

Return the inbound interceptor class used to scope graphs per run.

Undocumented

Undocumented