pub async fn get_pipeline(
pipeline_def: &PipelineDefinition,
handler: &PipelineHandlerRef,
query_ctx: &QueryContextRef,
) -> Result<Arc<Pipeline>>
Expand description
Never call this on GreptimeIdentityPipeline
because it’s a real pipeline