pub trait Monitor: Send + Sync { // Required method fn monitor(&self, data: &PipelineData<Box<dyn Any + Send + Sync>>); }