Подсчёт событий по окнам с допустимым опозданием

Напишите tumbling_counts(events, size, lateness).

• events — список пар (event_time, arrival_order) в порядке прихода; время — целые секунды. arrival_order можно не использовать.
• Окно события начинается с event_time // size * size.
• Watermark — максимальное event_time среди уже пришедших событий (до текущего). Событие считается опоздавшим, если конец окна + lateness <= watermark, где конец окна = начало + size. Опоздавшие не учитываются.
• Верните кортеж (counts, dropped): словарь начало окна → число событий и число отброшенных.

def tumbling_counts(events, size, lateness):
    # ваш код
    return None