Struct InMemoryArtifactStore 

pub struct InMemoryArtifactStore { /* private fields */ }

Implementations

impl InMemoryArtifactStore

pub fn new() -> Self

Trait Implementations

impl ArtifactStore for InMemoryArtifactStore

async fn put_outputs( &self, workflow_id: &str, job_id: &str, outputs: HashMap<String, String>, ) -> Result<(), ArtifactError>

Store key-value outputs for a completed job.

async fn get_outputs( &self, workflow_id: &str, job_id: &str, ) -> Result<HashMap<String, String>, ArtifactError>

Retrieve outputs for a specific job.

async fn get_upstream_outputs( &self, workflow_id: &str, job_ids: &[String], ) -> Result<HashMap<String, HashMap<String, String>>, ArtifactError>

Retrieve outputs for multiple upstream jobs at once.

impl Default for InMemoryArtifactStore

fn default() -> Self

Returns the “default value” for a type.