Struct SchedulerConfig 

pub struct SchedulerConfig {

    pub worker_id: String,
    pub claim_batch_size: usize,
    pub lease_ttl: Duration,
    pub tick_interval: Duration,
    pub heartbeat_interval: Duration,
    pub reclaim_interval: Duration,
    pub reclaim_grace: Duration,
    pub concurrency: ConcurrencyConfig,
    pub command_timeout: Option<Duration>,
    pub working_dir: String,
    pub task_gates: Vec<GateType>,
    pub run_gates: Vec<GateType>,
    pub enforce_policies: bool,
    pub audit_decisions: bool,
    pub budgets: ResourceBudgetConfig,
    pub allow_recursive_run: bool,
    pub max_runtime: Option<Duration>,
    pub idle_timeout: Option<Duration>,
}

Scheduler configuration.

Fields

worker_id: String

Worker identity for lease claims.

claim_batch_size: usize

How many tasks to claim per tick.

lease_ttl: Duration

Lease TTL for claimed tasks.

tick_interval: Duration

Interval between scheduler ticks.

heartbeat_interval: Duration

Interval between heartbeat sweeps.

reclaim_interval: Duration

Interval between stale lease reclamation sweeps.

reclaim_grace: Duration

Grace period for stale lease reclamation.

concurrency: ConcurrencyConfig

Concurrency configuration.

command_timeout: Option<Duration>

Default command timeout.

working_dir: String

Default working directory for commands.

task_gates: Vec<GateType>

Gates to evaluate for task-level verification. If empty, tasks auto-complete after successful execution.

run_gates: Vec<GateType>

Gates to evaluate for run-level verification. If empty, runs auto-complete after all tasks finish.

enforce_policies: bool

Enforce policy checks before command execution.

audit_decisions: bool

Emit policy/audit records when decisions are made.

budgets: ResourceBudgetConfig

Runtime resource and token budgets.

allow_recursive_run: bool

Allow task commands to recursively invoke yarli run.

max_runtime: Option<Duration>

Maximum wall-clock runtime for the entire scheduler loop. When elapsed, the run transitions to TimedOut.

idle_timeout: Option<Duration>

Idle timeout — if no task produces output or completes within this duration, the run transitions to StalledNoProgress.

Trait Implementations

impl Clone for SchedulerConfig

fn clone(&self) -> SchedulerConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SchedulerConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SchedulerConfig

fn default() -> Self

Returns the “default value” for a type.