У меня есть DAG, который запускается планировщиком воздушного потока и работает в течение 1 минуты, каждый день пропускается полночь. Я хочу изменить время начала каждый день, чтобы быть динамичным, о
Я настроил воздушный поток и создал несколько Dags и subDags, которые вызывают несколько операторов. Моя проблема в том, что, когда операторы запускают и завершают работу, я хотел бы получить результа
Я создал DAG с 3 задачами. Одна из задач не удалась, поэтому в пользовательском интерфейсе воздушного потока работа отображается как сбой. Но когда я делаю повторное заполнение предыдущих заданий. Теп
Местный исполнитель запускает новые процессы при планировании задач. Существует ли ограничение на количество процессов, которые он создает. Мне нужно было изменить его. Мне нужно знать, в чем разница