async fn write_prometheus_v2_rows_with_progress(
prom_store_handler: PromStoreProtocolHandlerRef,
pending_rows_batcher: Option<Arc<PendingRowsBatcher>>,
prom_store_with_metric_engine: bool,
sample_batches: Vec<(QueryContextRef, RowInsertRequests)>,
histogram_batches: Vec<(QueryContextRef, RowInsertRequests)>,
) -> Result<PromWriteV2Outcome, PromWriteV2Error>