Skip to main content

Module checkpoint

Module checkpoint 

Source
Expand description

Checkpoint system for resilient pipeline execution.

Provides checkpoint, checkpoint_get, and checkpoint_clear builtins. Checkpoints are persisted to <base_dir>/.harn/checkpoints/<pipeline>.json and survive pipeline crashes/timeouts. On resume, a pipeline can skip already-processed items by checking checkpoint_get.

Functionsยง

register_checkpoint_builtins
Register checkpoint builtins on a VM.