Function build_flush_pipe_sql

fn build_flush_pipe_sql(database: &str, schema: &str, pipe_name: &str) -> String