Bash в этом образе вроде должен стоять

А некоторые из пакетов добавлять всё же надо будет в билде, там есть аргументы airflow_deps и python_deps, посмотри вот тут описание - https://hub.docker.com/r/puckel/docker-airflow/

Попробуй так:
from airflow.operators.bash_operator import BashOperator

заработало, спасибо. Похоже использую туториал  прошлых версий.

Наоборот)

Всем привет. А в разработке версия убунты имеет какое-то критичное значение?

Было бы странно. А в чем реально вопрос?

Да вот мучаюсь с тестами.

sudo breeze --backend mysql --mysql-version 5.7 --python 3.8 --db-reset --test-type All  tests

Пытаюсь запустить, а они с ошибками

День добрый. Подскажите пожалуйста. Есть DAG, который проверяет наличие определенной строки в таблице БД, затем делает транкейт уже другой таблицы и инсертит в нее данные. Так вот, первые 2 пункта отрабатывают нормально, третий пункт работает, через пару минут падает с ошибкой, но при этом, запрос в базе продолжает работать и отрабатывает, но при этом через раз бывает, что запрос на insert запускается второй раз, в логах airflow ошибок и повторных запусков нет.

возможно где-то таймаут

Вопрос где, посмотрел конфиг, не нашел похожего, пробовал выставлять параметр execution_timeout, не помогло

а как вы коннекшн создаете?

Сам конекшн через веб интерфейс airflow

Далее указываю его в conn_id в таске

А через REST вообще можно выполнить аналог консольной airflow clear?

тут что-то очень грустно всё

из создания только пул и дагран...

Хм, у меня пока только есть идея автоматизировать запуск cli команд на сервере, но чот как костыль выглядит)

Есть какие-то более умные варианты?)

def clear_day_for_dags(dags, date):
    for dag in dags:
        system(f"yes yes | airflow clear --start_date {date} --end_date {date} {dag}")

вроде работает, но из минусов - надо прям в докер контейнере запускать в REPL питона