async fn write_batched_prometheus_v2_rows_with_progress<B: PromWriteBatcher + ?Sized>(
prom_store_handler: PromStoreProtocolHandlerRef,
batcher: &B,
prom_store_with_metric_engine: bool,
sample_batches: Vec<(QueryContextRef, RowInsertRequests)>,
histogram_batches: Vec<(QueryContextRef, RowInsertRequests)>,
) -> Result<PromWriteV2Outcome, PromWriteV2Error>