moadim 0.12.0

Moadim.io MCP/REST server for managing cron jobs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

//! Max-runtime (watchdog) config for in-flight routine runs.
//!
//! A run launches its agent in a detached tmux session that nothing otherwise bounds: a hung agent
//! (waiting on stdin, looping, blocked on a stuck network/git op) never exits, so the TTL reaper —
//! which only touches *finished* runs — can never reap it, and each cron tick stacks another zombie
//! session + workbench. The cleanup watchdog force-kills any session whose run has exceeded its
//! routine's max runtime, after which the workbench is reaped under the normal TTL rules.

use super::super::model::Routine;

/// Upper bound on a single run's wall-clock duration before the watchdog kills its session: 1h.
///
/// Mirrors the TTL cap ([`super::ttl::MAX_TTL_SECS`]): a run is only worth keeping alive until the
/// next run is due, and never longer than this. Also the fallback for orphaned workbenches whose
/// routine was since deleted.
pub const MAX_RUNTIME_SECS: u64 = 60 * 60;

impl Routine {
    /// Effective max runtime for a single run of this routine.
    ///
    /// Mirrors [`Routine::effective_ttl_secs`]: `min(MAX_RUNTIME_SECS, cron interval)`, then further
    /// lowered by an explicit `max_runtime_secs` if set. An explicit value can only shorten the
    /// bound, never raise it above the cron-derived cap.
    pub fn effective_max_runtime_secs(&self) -> u64 {
        let ceiling = MAX_RUNTIME_SECS.min(self.cron_interval_secs().unwrap_or(MAX_RUNTIME_SECS));
        self.max_runtime_secs
            .map_or(ceiling, |secs| secs.min(ceiling))
    }
}