airflow.providers.common.ai.durable.base¶

Shared interface for durable execution storage backends.

Attributes¶

`TOOL_RESULT_SENTINEL`
`DURABLE_KEY_PREFIX`

Classes¶

DurableStorageProtocol

Persistence contract shared by the durable execution storage backends.

Module Contents¶

airflow.providers.common.ai.durable.base.TOOL_RESULT_SENTINEL = '__durable_cached__'[source]¶

airflow.providers.common.ai.durable.base.DURABLE_KEY_PREFIX = '__commonai_durable__'[source]¶

class airflow.providers.common.ai.durable.base.DurableStorageProtocol[source]¶

Bases: Protocol

Persistence contract shared by the durable execution storage backends.

Implemented by both DurableStorage (ObjectStorage, Airflow < 3.3) and TaskStateStoreDurableStorage (AIP-103 task state store, Airflow >= 3.3). CachingModel and CachingToolset depend on this interface, not a concrete backend.

save_model_response(key, response, *, fingerprint)[source]¶

load_model_response(key)[source]¶

save_tool_result(key, result, *, fingerprint)[source]¶

load_tool_result(key)[source]¶

cleanup()[source]¶