pub fn visit_stream_node_source_backfill( stream_node: &StreamNode, f: impl FnMut(&SourceBackfillNode), )