async fn write_batches(
writer: &SharedBatchWriter,
desc: &BatchDescription,
updates_rx: &mut Receiver<Vec<((SourceData, ()), Timestamp, StorageDiff)>>,
) -> Vec<ProtoBatch>Expand description
Write the updates for desc through writer, returning the batches this worker delivers.