MCPcopy Create free account
hub / github.com/atomicdotdev/atomic / acknowledge_checkpoint

Method acknowledge_checkpoint

atomic-cli/src/commands/agent/owner.rs:429–453  ·  view source on GitHub ↗
(
        &self,
        checkpoint: &JournalCheckpointAttempt,
        manifest_hash: Hash,
        completed_at: i64,
    )

Source from the content-addressed store, hash-verified

427 }
428
429 fn acknowledge_checkpoint(
430 &self,
431 checkpoint: &JournalCheckpointAttempt,
432 manifest_hash: Hash,
433 completed_at: i64,
434 ) -> Result<(), String> {
435 let repository = self.repository.clone();
436 let provenance_id = checkpoint.provenance_id;
437 let expected_generation = checkpoint.attempt_generation;
438 run_outside_async_runtime(move || {
439 match request_with_reconnect(
440 &repository,
441 OwnerRequest::AcknowledgeCheckpoint {
442 provenance_id,
443 expected_generation,
444 manifest_hash,
445 completed_at,
446 },
447 )? {
448 OwnerResponse::CheckpointAcknowledged => Ok(()),
449 other => Err(unexpected_response("acknowledge checkpoint", other)),
450 }
451 })
452 .map_err(|error| error.to_string())
453 }
454
455 fn stop_turn(
456 &self,

Callers

nothing calls this directly

Calls 4

request_with_reconnectFunction · 0.85
unexpected_responseFunction · 0.85
cloneMethod · 0.45

Tested by

no test coverage detected