Function run_data_pipeline 

async fn run_data_pipeline(script: &str, steps: u32) -> Result<()>