module documentation

LangGraph plugin for running LangGraph nodes and tasks as Temporal activities.

Function _constant_summary_fn Adapt a static summary string to the summary_fn interface.
Function _merge_activity_opts Layer per-node/task options over the plugin defaults.
Constant _ACTIVITY_OPTION_KEYS Undocumented
Constant _LANGGRAPH_OPTION_KEYS Undocumented
def _constant_summary_fn(value: str) -> Callable[[tuple[Any, ...], dict[str, Any]], str]: (source)

Adapt a static summary string to the summary_fn interface.

def _merge_activity_opts(defaults: dict[str, Any] | None, specific: dict[str, Any]) -> dict[str, Any]: (source)

Layer per-node/task options over the plugin defaults.

summary and summary_fn are two forms of one setting, so a node or task that supplies either form overrides an inherited default of either form, rather than coexisting with it and tripping the exclusivity check.

_ACTIVITY_OPTION_KEYS: frozenset[str] = (source)

Undocumented

Value
frozenset(set(['execute_in',
               *inspect.signature(workflow.execute_activity).parameters]))
_LANGGRAPH_OPTION_KEYS: frozenset[str] = (source)

Undocumented

Value
_ACTIVITY_OPTION_KEYS | frozenset(set(['summary_fn']))