Skip to main content

vv_agent/runtime/backends/
distributed.rs

1#[cfg(feature = "apalis")]
2pub mod apalis;
3mod backend;
4mod capabilities;
5mod checkpoint;
6mod checkpointed_cycle;
7mod contract;
8mod dispatch;
9mod execution;
10mod r#loop;
11mod loop_v2;
12mod worker;
13mod worker_v2;
14
15pub use backend::DistributedBackend;
16pub use capabilities::{
17    toolset_schema_digest, DistributedCapabilityError, DistributedCapabilityRegistry,
18    ResolvedDistributedCapabilities, ResolvedDistributedCheckpointExtension,
19};
20pub use checkpointed_cycle::run_checkpointed_cycle;
21pub use contract::{
22    CapabilityRef, DistributedCapabilities, DistributedCheckpointConfig,
23    DistributedCheckpointExtensionRef, DistributedRunEnvelope, DistributedToolPolicy, ToolsetRef,
24    DEFAULT_CYCLE_NAME, DEFAULT_LEASE_DURATION_MS, DEFAULT_TOOLSET_ID,
25    DEFAULT_TOOLSET_SCHEMA_DIGEST, DEFAULT_TOOLSET_VERSION, DISTRIBUTED_RUN_SCHEMA_VERSION,
26    DISTRIBUTED_RUN_SCHEMA_VERSION_V1, DISTRIBUTED_RUN_SCHEMA_VERSION_V2,
27};
28pub use dispatch::{CycleDispatchResult, CycleDispatcher};
29pub use worker::DistributedCycleWorker;
30pub use worker_v2::{
31    DistributedCheckpointProgress, DistributedDeliveryMetadata, DistributedV2CycleExecutor,
32    DistributedV2CycleOutcome,
33};