async def METHOD_NAME(self) -> None:
    async def _process_activity_log_events_since(mark):
        return await process_activity_log_events_since(
            self.db,
            self.inst_coll_manager,
            self.activity_logs_client,
            self.zone_monitor.zone_success_rate,
            self.machine_name_prefix,
            self.project,
            mark,
        )
    await process_outstanding_events(self.db, _process_activity_log_events_since)