pub trait DeadLetterStore: Send + Sync {
// Required methods
fn push_dead_letter(
&self,
dead_letter: PipelineDeadLetter,
) -> DataResult<()>;
fn list_dead_letters(
&self,
run_id: &str,
) -> DataResult<Vec<PipelineDeadLetter>>;
}