run_due

Function run_due 

Source
pub fn run_due(
    store: &EmbeddedAnalytics,
    cfg: &AnalyticsExports,
    quota_at: &dyn Fn(i64, i64) -> HashMap<String, QuotaFigures>,
    now_ms: i64,
) -> Vec<ExportRun>
Expand description

The scheduler’s per-tick entry (DW-120): export every closed, settled window of the configured kind that has no successful run record yet — oldest first, bounded by MAX_CATCHUP_WINDOWS per tick and by the query granularity’s retention horizon (windows past it would be partial; a manual trigger can still force them). Failed runs are retried on later ticks, at most once per FAILURE_RETRY_MS window (the backoff).