pub(crate) fn build_oneshot_ingestion_dataflow<A: Allocate>(
timely_worker: &mut Worker<A>,
storage_state: &mut StorageState,
ingestion_id: Uuid,
collection_id: GlobalId,
collection_meta: CollectionMetadata,
description: OneshotIngestionRequest,
)