Не получается, я тут придумал два других простых решения...
Запускать или через api
Или через башоператор, который выполнит airflow dags ....

ТК мне не нужно получать результат выполнения...

А что не получается-то?

Контекст передать

Я ж его в питон оператор не передаю даже

Соответственно его в нем нет, я думаю

А почему-то нельзя просто triggerdag оператор использовать?

Ну типа напрямую не из Python operator

Эм...

Не получается вызвать context=get_current_context(), а потом triggerdagrunoperator.execute(context)?

Не работал раньше с контекстом)

Попробую

Я же ссылку на доку не просто так дал)
А вообще можно просто тригердагоператором, верно говорят. Я не заметил, что там логики-то нет никакой в питоноператоре

Спасибо, всё получилось! )))

Жаль, я надеялся увидеть как у вас тут будет башоператор выполняюший airflow dags....

:)

Коллеги, кто нибудь углублялся как работает команда: airflow tasks run dag_id task_id ex_date ? я этой командой дебажу таски по отдельности на локальной машине. запускаю таск с разными  ex_date и смотрю через Web UI TaskInstance логи. но сегодня столкнулся с проблемой, что не появляются новые TaskInstance после запуска через airflow tasks run . я много пробовал как пофикисть это, в том числе и хардкор методы: удаление БД и переименование дага и тасок, но проблема не решилась. новые  (простые) даги создают TaskInstance. я после экспериментов заметил, что если комментирую связи в даг файле - все начинает работать.  даг парситься норм  и строит  корректно связи в  Web UI. Вопрос: знает ли кто нибудь как airflow tasks run связан со связями определные в даг файле (кроме того что airflow парсит этот файл, инициализирует все таски и связи).  Инфо: airflow 2.0.1, даг имеет много таско но простые линейние связи.

может кто нибудь заодно и поделиться как вы дебажите таски (инициализированные операторы) в дагах (не даги, вариант каждый раз запускать даг - не предлагать🙈😉)

Принтами в логах 😁

Скажите, а как то можно получить информацию по dag_id (но не в текущем таске, а из общего списка всех дагов на сервере), в частности:
- последняя дата запуска
- последний статус
- следующий запуск