airflow.providers.common.ai.durable.step_counter¶

Shared step counter for durable execution caching.

Classes¶

DurableStepCounter

Monotonically increasing counter shared between CachingModel and CachingToolset.

Module Contents¶

class airflow.providers.common.ai.durable.step_counter.DurableStepCounter[source]¶

Monotonically increasing counter shared between CachingModel and CachingToolset.

Each model call and tool call increments the counter. The step index is used as the cache key; replay correctness is verified separately by comparing the request fingerprint stored with each cache entry (see airflow.providers.common.ai.durable.fingerprint).

replayed_model: int = 0[source]¶

replayed_tool: int = 0[source]¶

cached_model: int = 0[source]¶

cached_tool: int = 0[source]¶

next_step()[source]¶

Return the current step and advance the counter.

property total_steps: int[source]¶

Total number of steps executed so far.