async fn build_loki_context_req(
handler: &PipelineHandlerRef,
content_type: ContentType,
table_name: String,
pipeline_info: PipelineInfo,
bytes: Bytes,
ctx: &QueryContextRef,
) -> Result<ContextReq>async fn build_loki_context_req(
handler: &PipelineHandlerRef,
content_type: ContentType,
table_name: String,
pipeline_info: PipelineInfo,
bytes: Bytes,
ctx: &QueryContextRef,
) -> Result<ContextReq>