pub fn process_statistics<G, FromTime>(
scope: G,
source_id: GlobalId,
worker_id: usize,
stats_stream: Stream<G, ProgressStatisticsUpdate>,
source_statistics: SourceStatistics,
)where
G: Scope<Timestamp = FromTime>,
FromTime: SourceTimestamp,