This also fixes the largest queued timestamp to be the correct value if upstream samples are discarded. ------------- Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=120207054
