fn update_progress( current_input_frontier: &mut Antichain<Timestamp>, new_input_frontier: AntichainRef<'_, Timestamp>) -> Option<Antichain<Timestamp>>