Function run_stream 

pub async fn run_stream(
    project_root: &Path,
    event_type: &str,
) -> Result<(), Box<dyn Error>>