scheduler: extract magic numbers and deduplicate output logic

- Add SCHEDULE_TOLERANCE_MS constant for cron matching tolerance
- Add AUTO_JITTER_RATIO constant for default jitter calculation
- Extract print_output_lines helper to reduce code duplication

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: aster-void

src/scheduler/backoff.rs

@@ -3,9 +3,13 @@ use std::time::Duration;
 
 use crate::config::RetryConfig;
 
+/// Default jitter ratio when not explicitly configured (25% of base delay)
+const AUTO_JITTER_RATIO: u32 = 25;
+
 pub fn calculate_backoff(retry: &RetryConfig, attempt: u32) -> Duration {
     let base_delay = retry.delay.saturating_mul(2u32.saturating_pow(attempt));
-    let jitter_max = retry.jitter.unwrap_or_else(|| retry.delay.saturating_mul(25) / 100);
+    let jitter_max =
+        retry.jitter.unwrap_or_else(|| retry.delay.saturating_mul(AUTO_JITTER_RATIO) / 100);
     base_delay.saturating_add(generate_jitter(jitter_max))
 }
 

src/scheduler/executor.rs

@@ -81,6 +81,19 @@ enum CommandResult {
     Timeout,
 }
 
+fn print_output_lines(tag: &str, output: &str, use_stderr: bool) {
+    if output.trim().is_empty() {
+        return;
+    }
+    for line in output.lines() {
+        if use_stderr {
+            eprintln!("{}   | {}", tag, line);
+        } else {
+            println!("{}   | {}", tag, line);
+        }
+    }
+}
+
 fn handle_result(tag: &str, job: &Job, result: &CommandResult) -> bool {
     match result {
         CommandResult::Completed(output) => {
@@ -89,24 +102,12 @@ fn handle_result(tag: &str, job: &Job, result: &CommandResult) -> bool {
 
             if output.status.success() {
                 println!("{} ✓ Completed", tag);
-                if !stdout.trim().is_empty() {
-                    for line in stdout.lines() {
-                        println!("{}   | {}", tag, line);
-                    }
-                }
+                print_output_lines(tag, &stdout, false);
                 true
             } else {
                 eprintln!("{} ✗ Failed (exit code: {:?})", tag, output.status.code());
-                if !stderr.trim().is_empty() {
-                    for line in stderr.lines() {
-                        eprintln!("{}   | {}", tag, line);
-                    }
-                }
-                if !stdout.trim().is_empty() {
-                    for line in stdout.lines() {
-                        eprintln!("{}   | {}", tag, line);
-                    }
-                }
+                print_output_lines(tag, &stderr, true);
+                print_output_lines(tag, &stdout, true);
                 false
             }
         }

src/scheduler/mod.rs

@@ -218,14 +218,17 @@ impl Scheduler {
 
 // === Helper Functions ===
 
+/// Tolerance for schedule matching (accounts for 1-second tick interval)
+const SCHEDULE_TOLERANCE_MS: i64 = 1000;
+
 fn is_job_due<Z: TimeZone>(schedule: &cron::Schedule, tz: Z) -> bool
 where
     Z::Offset: std::fmt::Display,
 {
     let now = Utc::now().with_timezone(&tz);
     if let Some(next) = schedule.upcoming(tz).next() {
         let until_next = (next - now).num_milliseconds();
-        until_next <= 1000 && until_next >= 0
+        until_next <= SCHEDULE_TOLERANCE_MS && until_next >= 0
     } else {
         false
     }