pub trait PipelineEventStore: Send + Sync {
// Required methods
fn append_event(&self, event: PipelineEvent) -> DataResult<()>;
fn list_events(&self, run_id: &str) -> DataResult<Vec<PipelineEvent>>;
}pub trait PipelineEventStore: Send + Sync {
// Required methods
fn append_event(&self, event: PipelineEvent) -> DataResult<()>;
fn list_events(&self, run_id: &str) -> DataResult<Vec<PipelineEvent>>;
}