pub fn render<G: Scope<Timestamp = MzOffset>>(
key_value: KeyValueLoadGenerator,
scope: &mut G,
config: RawSourceCreationConfig,
committed_uppers: impl Stream<Item = Antichain<MzOffset>> + 'static,
start_signal: impl Future<Output = ()> + 'static,
output_map: BTreeMap<LoadGeneratorOutput, Vec<usize>>,
) -> (StackedCollection<G, (usize, Result<SourceMessage, DataflowError>)>, Option<Stream<G, Infallible>>, Stream<G, HealthStatusMessage>, Stream<G, ProgressStatisticsUpdate>, Vec<PressOnDropButton>)