harnest.durable

All Python modules · Import and compatibility guidance

Exports

Name	Kind
`NativeDurableCall`	Class
`NativeDurableSuspended`	Class
`NativeResumeInput`	Class
`ResumeArtifact`	Class
`adk_durable_tool`	Function
`current_native_durable_call`	Function
`is_durable_tool`	Function
`langgraph_durable_callable`	Function
`native_durable_call`	Function

NativeDurableCall

Active native call identity inherited by plugin continuation ports.

NativeDurableCall(artifact: ResumeArtifact) -> None

Fields (— means no declared default):

Field	Type	Default
`artifact`	`ResumeArtifact`	`—`

Parameters and example

Parameter	Type	Default
`artifact`	`ResumeArtifact`	Required

from harnest.durable import NativeDurableCall

call = NativeDurableCall(artifact=...)

NativeDurableCall.submission_key

NativeDurableCall.submission_key(
    *,
    application_id: str,
    user_id: str,
    session_id: str,
    run_id: str,
    provider: str,
    capability: str,
) -> str

Derive a stable opaque key that survives framework node replay.

Parameters and example

Parameter	Type	Default
`application_id`	`str`	Required
`user_id`	`str`	Required
`session_id`	`str`	Required
`run_id`	`str`	Required
`provider`	`str`	Required
`capability`	`str`	Required

from harnest.durable import NativeDurableCall

call: NativeDurableCall
result = call.submission_key(
    application_id=...,
    user_id=...,
    session_id=...,
    run_id=...,
    provider=...,
    capability=...,
)

NativeDurableCall.suspend

NativeDurableCall.suspend(pending: Any) -> Any

Enter the selected framework’s persisted suspension primitive.

Parameters and example

Parameter	Type	Default
`pending`	`Any`	Required

from harnest.durable import NativeDurableCall

call: NativeDurableCall
result = call.suspend(pending=...)

NativeDurableSuspended

Control flow raised after a framework durably records an external wait.

Example

from harnest.durable import NativeDurableSuspended

try:
    ...
except NativeDurableSuspended as error:
    ...

NativeResumeInput

Private input that asks a framework driver to resume one saved call.

NativeResumeInput(artifact: ResumeArtifact, value: Any) -> None

Fields (— means no declared default):

Field	Type	Default
`artifact`	`ResumeArtifact`	`—`
`value`	`Any`	`—`

Parameters and example

Parameter	Type	Default
`artifact`	`ResumeArtifact`	Required
`value`	`Any`	Required

from harnest.durable import NativeResumeInput

native_resume_input = NativeResumeInput(artifact=..., value=...)

ResumeArtifact

Private framework identity required to resume one persisted tool call.

ResumeArtifact(
    framework: Literal['adk', 'langgraph'],
    native_invocation_id: str,
    tool_call_id: str,
    tool_name: str,
    version: str = 'harnest-continuation/v1',
) -> None

Fields (— means no declared default):

Field	Type	Default
`framework`	`Literal['adk', 'langgraph']`	`—`
`native_invocation_id`	`str`	`—`
`tool_call_id`	`str`	`—`
`tool_name`	`str`	`—`
`version`	`str`	`'harnest-continuation/v1'`

Parameters and example

Parameter	Type	Default
`framework`	`Literal['adk', 'langgraph']`	Required
`native_invocation_id`	`str`	Required
`tool_call_id`	`str`	Required
`tool_name`	`str`	Required
`version`	`str`	`'harnest-continuation/v1'`

from harnest.durable import ResumeArtifact

artifact = ResumeArtifact(
    framework=...,
    native_invocation_id=...,
    tool_call_id=...,
    tool_name=...,
)

ResumeArtifact.public_dict

ResumeArtifact.public_dict() -> dict[str, str]

Serialize only stable framework identity for durable persistence.

Example

from harnest.durable import ResumeArtifact

artifact: ResumeArtifact
result = artifact.public_dict()

ResumeArtifact.from_mapping

ResumeArtifact.from_mapping(value: Mapping[str, Any]) -> 'ResumeArtifact'

Restore persisted identity without accepting extra compatibility fields.

Parameters and example

Parameter	Type	Default
`value`	`Mapping[str, Any]`	Required

from harnest.durable import ResumeArtifact

artifact = ResumeArtifact.from_mapping(value=...)

adk_durable_tool

Lower a durable callable to ADK’s native long-running tool boundary.

adk_durable_tool(value: Callable[..., Any]) -> Any

Parameters and example

Parameter	Type	Default
`value`	`Callable[..., Any]`	Required

from harnest.durable import adk_durable_tool

result = adk_durable_tool(value=...)

current_native_durable_call

Return the active framework call without exposing mutation authority.

current_native_durable_call() -> NativeDurableCall | None

Example

from harnest.durable import current_native_durable_call

call = current_native_durable_call()

is_durable_tool

Read the marker propagated through Harnest and framework wrappers.

is_durable_tool(value: Any) -> bool

Parameters and example

Parameter	Type	Default
`value`	`Any`	Required

from harnest.durable import is_durable_tool

result = is_durable_tool(value=...)

langgraph_durable_callable

Inject LangGraph’s native tool and thread identities into a callable.

langgraph_durable_callable(value: Callable[..., Any]) -> Callable[..., Any]

Parameters and example

Parameter	Type	Default
`value`	`Callable[..., Any]`	Required

from harnest.durable import langgraph_durable_callable

@langgraph_durable_callable
def my_function():
    ...

native_durable_call

Bind native identity only for the dynamic extent of one durable tool.

native_durable_call(artifact: ResumeArtifact) -> Iterator[None]

Parameters and example

Parameter	Type	Default
`artifact`	`ResumeArtifact`	Required

from harnest.durable import native_durable_call

with native_durable_call(artifact=...):
    ...

Overview

Get started

Harnest Studio

Guides

API reference

harnest.durable

Exports

NativeDurableCall

NativeDurableCall.submission_key

NativeDurableCall.suspend

NativeDurableSuspended

NativeResumeInput

ResumeArtifact

ResumeArtifact.public_dict

ResumeArtifact.from_mapping

adk_durable_tool

current_native_durable_call

is_durable_tool

langgraph_durable_callable

native_durable_call

​Exports

​NativeDurableCall

​NativeDurableCall.submission_key

​NativeDurableCall.suspend

​NativeDurableSuspended

​NativeResumeInput

​ResumeArtifact

​ResumeArtifact.public_dict

​ResumeArtifact.from_mapping

​adk_durable_tool

​current_native_durable_call

​is_durable_tool

​langgraph_durable_callable

​native_durable_call

Exports

NativeDurableCall

NativeDurableCall.submission_key

NativeDurableCall.suspend

NativeDurableSuspended

NativeResumeInput

ResumeArtifact

ResumeArtifact.public_dict

ResumeArtifact.from_mapping

adk_durable_tool

current_native_durable_call

is_durable_tool

langgraph_durable_callable

native_durable_call