pub(crate) fn run_chunk_into_accumulator_for_merge(
run: ChunkRun<'_>,
progress: &dyn ProgressSink,
handler_factory: impl Fn() -> Result<ResolvedHandler, ApplicationError>,
) -> Result<TelemetryAccumulator, ApplicationError>pub(crate) fn run_chunk_into_accumulator_for_merge(
run: ChunkRun<'_>,
progress: &dyn ProgressSink,
handler_factory: impl Fn() -> Result<ResolvedHandler, ApplicationError>,
) -> Result<TelemetryAccumulator, ApplicationError>