Function gen_workflow_checkpoint

core/tests/test_persisted_schema_roundtrip.rs:623–637

(rng: &mut Rng)

}

fn gen_workflow_checkpoint(rng: &mut Rng) -> WorkflowCheckpoint {
    let n = rng.below(4);
    WorkflowCheckpoint {
        // Stay at-or-below the current version (future versions are rejected).
        schema_version: rng.below(u64::from(WORKFLOW_CHECKPOINT_SCHEMA_VERSION) + 1) as u32,
        workflow_id: rng.string(),
        steps: (0..n)
            .map(|_| WorkflowStepRecord {
                task_id: rng.string(),
                outcome: gen_step_outcome(rng),
            })
            .collect(),
        checkpoint_ms: rng.u64_small(),
    }
}

#[test]
fn fuzz_roundtrip_all_persisted_types() {