Какой из следующих механизмов **наиболее эффективен для обработки данных с задержкой** (late data) в Airflow?