neograph::graph::ResumeContext Struct Reference

Context needed to resume execution from the last saved snapshot. More...

#include <coordinator.h>

Public Attributes
BarrierState	barrier_state
	Barrier accumulators for in-flight AND-joins.
json	channel_values
	Serialized GraphState at cp time.
std::unordered_map< std::string, NodeResult >	replay_results
	Partially-completed super-step writes, keyed by task_id.
int	start_step = 0
	Phase-adjusted step to re-enter at.

Detailed Description

Context needed to resume execution from the last saved snapshot.

Populated by CheckpointCoordinator::load_for_resume(). When have_cp is false, the caller should treat this as a "nothing to resume from" signal and fall through to a fresh run.

Definition at line 49 of file coordinator.h.

Member Data Documentation

barrier_state

BarrierState neograph::graph::ResumeContext::barrier_state

Barrier accumulators for in-flight AND-joins.

Present since schema v2; empty for v1 blobs.

Definition at line 65 of file coordinator.h.

replay_results

std::unordered_map<std::string, NodeResult> neograph::graph::ResumeContext::replay_results

Partially-completed super-step writes, keyed by task_id.

The engine replays any task whose id is in this map instead of re-executing the node.

Definition at line 61 of file coordinator.h.

---

The documentation for this struct was generated from the following file:

• include/neograph/graph/coordinator.h