Function run_custom_pipeline

async fn run_custom_pipeline(
    handler: &PipelineHandlerRef,
    pipeline_definition: &PipelineDefinition,
    pipeline_parameters: &GreptimePipelineParams,
    data_array: Vec<PipelineMap>,
    table_name: String,
    query_ctx: &QueryContextRef,
    is_top_level: bool,
) -> Result<Vec<RowInsertRequest>>