Skip to main content

Scheduling overview

Reqon supports scheduling missions to run automatically at specified intervals or times.

Schedule types​

TypeSyntaxExample
Intervalevery N unitsevery 6 hours
Croncron "expression"cron "0 */6 * * *"
One-timeat "datetime"at "2024-01-20 09:00 UTC"

Quick start​

mission DailySync {
  schedule: every 1 days

  source API { auth: bearer, base: "https://api.example.com" }
  store data: file("data")

  action Sync {
    get "/data" { since: lastSync }
    store response -> data { key: .id }
  }

  run Sync
}

Running scheduled missions​

Daemon mode​

Run continuously:

reqon ./missions/ --daemon

One-shot mode​

Run once and exit:

reqon ./missions/ --once

Interval scheduling​

// Every N minutes
schedule: every 15 minutes

// Every N hours
schedule: every 6 hours

// Every N days
schedule: every 1 days

// Every N weeks
schedule: every 1 weeks

Cron scheduling​

Full cron expression support:

// Every day at midnight
schedule: cron "0 0 * * *"

// Every hour
schedule: cron "0 * * * *"

// Every 6 hours
schedule: cron "0 */6 * * *"

// Weekdays at 9am
schedule: cron "0 9 * * 1-5"

// First of month at 6am
schedule: cron "0 6 1 * *"

One-time scheduling​

// Specific datetime
schedule: at "2024-12-25 00:00 UTC"

// ISO format
schedule: at "2024-01-20T09:00:00Z"

Schedule options​

Options live inside an optional { } block attached to the schedule. They aren't mission-level fields.

mission ConfiguredSync {
  schedule: every 1 hours {
    // Timezone for cron and one-time schedules
    timezone: "UTC"

    // Concurrency control
    maxConcurrency: 5

    // Skip if a previous run is still going
    skipIfRunning: true

    // Retry the whole mission if a run fails
    retry: {
      maxRetries: 3,
      delaySeconds: 60
    }
  }
}

The retry block takes maxRetries (default 3) and delaySeconds (default 60). There's no backoff strategy on schedule retries; the delay between attempts is fixed.

Multiple missions​

Each mission has its own schedule:

mission FrequentSync {
  schedule: every 15 minutes
  // ...
}

mission DailyReport {
  schedule: every 1 days
  // ...
}

mission WeeklyCleanup {
  schedule: cron "0 0 * * 0"  // Sundays at midnight
  // ...
}

Execution context​

Last run time​

Access when mission last ran:

action IncrementalSync {
  get "/data" {
    since: lastSync  // Uses last successful completion time
  }
}

Best practices​

Use incremental sync​

mission EfficientSync {
  schedule: every 15 minutes

  action Sync {
    get "/data" { since: lastSync }  // Only fetch changes
    store response -> data { key: .id, upsert: true }
  }
}

Add error handling​

mission RobustSync {
  schedule: every 1 hours {
    retry: {
      maxRetries: 3,
      delaySeconds: 60
    }
  }

  action Sync {
    get "/data"

    match response {
      _ where response.error -> abort "Sync failed",
      _ -> store response -> data { key: .id }
    }
  }
}

Monitor execution​

mission MonitoredSync {
  schedule: every 1 hours

  store syncLog: file("sync-log")

  action Sync {
    store { started: now() } -> syncLog

    get "/data"
    store response -> data { key: .id }

    store {
      completed: now(),
      itemCount: length(response)
    } -> syncLog
  }
}

Next steps​