temporalio.contrib.langgraph._activity

module documentation
(source)

Activity wrappers for executing LangGraph nodes and tasks.

Class ActivityInput Input for a LangGraph activity, containing args, kwargs, and config.
Class ActivityOutput Output from an Activity, containing result, command, or interrupts.
Function clear_store_warning Drop the store-warning dedupe entry for a workflow run.
Function wrap_activity Wrap a function as a Temporal activity that handles LangGraph config and interrupts.
Function wrap_execute_activity Wrap an activity function to be called via workflow.execute_activity with caching.
Variable _warned_store_runs Undocumented
def clear_store_warning(run_id: str): (source)

Drop the store-warning dedupe entry for a workflow run.

def wrap_activity(func: Callable) -> Callable[[ActivityInput], Awaitable[ActivityOutput]]: (source)

Wrap a function as a Temporal activity that handles LangGraph config and interrupts.

def wrap_execute_activity(afunc: Callable[[ActivityInput], Awaitable[ActivityOutput]], task_id: str = '', **execute_activity_kwargs: Any) -> Callable[..., Any]: (source)

Wrap an activity function to be called via workflow.execute_activity with caching.

_warned_store_runs: set[str] = (source)

Undocumented