Struct ExecutionLog 

pub struct ExecutionLog {
    pub tasks: HashMap<String, TaskRecord>,
    pub current_step: usize,
}

Available on crate feature graph only.

Tracks task completion status within a workflow run. Stored as part of the checkpoint metadata.

Example

use adk_graph::functional::ExecutionLog;

let mut log = ExecutionLog::new();
log.record_start("step_a");
log.record_completion("step_a", serde_json::json!({"result": 42}));

assert!(log.is_completed("step_a"));
assert_eq!(log.get_result("step_a"), Some(&serde_json::json!({"result": 42})));

Fields

tasks: HashMap<String, TaskRecord>

Map of task_id -> completion record

current_step: usize

Current workflow step counter

Implementations

impl ExecutionLog

pub fn new() -> ExecutionLog

Available on crate feature functional only.

Create a new empty execution log.

pub fn get_result(&self, task_id: &str) -> Option<&Value>

Available on crate feature functional only.

Get the cached result for a completed task.

Returns Some(&Value) if the task is completed and has a result, None otherwise.

pub fn is_completed(&self, task_id: &str) -> bool

Available on crate feature functional only.

Check if a task was already completed in a prior run.

pub fn record_start(&mut self, task_id: &str)

Available on crate feature functional only.

Mark a task as running, recording the start timestamp.

pub fn record_completion(&mut self, task_id: &str, result: Value)

Available on crate feature functional only.

Mark a task as completed with a result value.

pub fn record_failure(&mut self, task_id: &str, error: &str)

Available on crate feature functional only.

Mark a task as failed with an error message.

pub fn current_step(&self) -> usize

Available on crate feature functional only.

Get the current step number.

pub fn advance_step(&mut self) -> usize

Available on crate feature functional only.

Increment the step counter and return the new value.

Trait Implementations

impl Clone for ExecutionLog

fn clone(&self) -> ExecutionLog

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionLog

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for ExecutionLog

fn default() -> ExecutionLog

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExecutionLog

fn deserialize<__D>( __deserializer: __D, ) -> Result<ExecutionLog, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExecutionLog

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.