resonate-durable-sleep-scheduled-work-rust

Resonate Durable Sleep + Scheduled Work — Rust

SDK note (0.6.0). The Rust SDK is in active development. This skill covers two features in the current release: ctx.sleep(Duration) for in-workflow durable sleep, and resonate.schedule(name, cron, fn, input) for cron-registered ephemeral-world scheduling. (Note: Python's resonate-sdk 0.7.4 also has a top-level resonate.schedule(...) now — confirmed against the installed package; see the cross-SDK asymmetry note below for what's still Rust/TypeScript-only.)

Overview

Two related but distinct capabilities:

1. Durable sleep inside a workflow — ctx.sleep(Duration) pauses execution; the worker process is free to exit and resume days later without the sleep "losing its place."
2. Cron-scheduled invocation from the ephemeral world — resonate.schedule(...) registers a function to fire on a cron schedule until explicitly deleted.

Both are Rust-idiomatic — Duration for in-workflow time, cron strings for cron schedules. Both are durable; Resonate holds the continuation in its store, not in a long-running process.

Durable sleep: ctx.sleep(Duration)

use resonate::prelude::*;
use std::time::Duration;

#[resonate::function]
async fn daily_reminder(ctx: &Context, user_id: String) -> Result<()> {
    loop {
        ctx.sleep(Duration::from_secs(24 * 60 * 60)).await?; // 24 hours
        ctx.rpc::<()>("send_reminder", user_id.clone()).await?;
    }
}

No upper bound on sleep duration. The worker process can exit after the .await? — Resonate's server holds the continuation and re-dispatches when the sleep expires.

Reminder workflows

#[resonate::function]
async fn seven_day_renewal_reminder(ctx: &Context, subscription_id: String) -> Result<()> {
    // 7 days before renewal
    ctx.sleep(Duration::from_secs(7 * 24 * 60 * 60)).await?;
    ctx.rpc::<()>("send_renewal_warning", subscription_id.clone()).await?;

    // 1 day before renewal
    ctx.sleep(Duration::from_secs(6 * 24 * 60 * 60)).await?;
    ctx.rpc::<()>("send_final_warning", subscription_id.clone()).await?;

    // renewal day
    ctx.sleep(Duration::from_secs(24 * 60 * 60)).await?;
    ctx.rpc::<()>("charge_renewal", subscription_id).await?;

    Ok(())
}