servers::pipeline

Function run_identity_pipeline

Source
async fn run_identity_pipeline(
    handler: &PipelineHandlerRef,
    custom_ts: Option<&IdentityTimeIndex>,
    pipeline_parameters: &GreptimePipelineParams,
    pipeline_req: PipelineIngestRequest,
    query_ctx: &QueryContextRef,
) -> Result<Vec<RowInsertRequest>>