Для сенсора нужен один график, насколько я понял

Иначе он не запускается

ну дык говорите что у вас в определенное время запускается 2ой

Наверное вам пулы надо посмотреть

Ок. Один будет завязан через сенсор, а как второй процес не стартануть?

ну вот с семафором каким-нибудь вполне ок
можно хоть в бд ставить флажок.
И в начале каждого дага сенсор на этот семафор.

главное, не забыть его снимать, в т.ч. в случае падений

ну и ставить его в одну транзакцию, чтобы не было такого, что оба его проверили, он свободен и поехали работать. хотя это и подразумевает семафор

Пардоньте, можете свой сенсор тогда состряпать, который будет чекать нет ли активных дагранов у 2ого процесса.

спасибо

dag serialization включен?

неа

А в я issue всё-таки что-то есть?)

https://issues.apache.org/jira/browse/AIRFLOW-2219?focusedCommentId=16932479&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16932479
у меня тоже на tiggerdagrunoperator проблема, но я чет пока не вкурил почему это как-то решает проблему
чел просто проверяет существование даграна
мб если его апишка trigger_dag создает, то какие-то проблемы могут быть

не знаю, что делает tiggerdagrunoperator, но похоже на то, что он пытается создать инстант даграна, который в таблице уже есть

В общем, надо ковырять код, благо трейс есть в логах)

всем привет. писал кто нить html страницы? пробую сделать плагин по доке - то одного компонента нет, то другого.  может есть у кого пример или ссылка на нормальный пример?

Добро пожаловать в самое дружелюбное комьюнити.

СДелал по данному примеру :

from airflow.plugins_manager import AirflowPlugin
from flask_appbuilder import BaseView as AppBuilderBaseView

class TestAppBuilderBaseView(AppBuilderBaseView):

    template_folder = '/home/user/airflow/plugins/test_plugin/templates'

    @expose("/")
    def list(self):
        return self.render_template("test.html", content="Hello galaxy!")

v_appbuilder_view = TestAppBuilderBaseView()
v_appbuilder_package = {"name": "Test View",
                        "category": "Test Plugin",
                        "view": v_appbuilder_view}

class AirflowTestPlugin(AirflowPlugin):
    name = "test_plugin"
    appbuilder_views = [v_appbuilder_package]

структуру имею вот такую

Plugins
|_test_plugin
   |_templates
      |_test.html
   test_plugin.py

по какому урлу найти данную страницу? с блюпринтом и фласком дел не имел пока что

как-то закидывал вопрос про сериализацию объекта сессии БД в XCOM, говорили что можно)
по-факту pickle отсылает с "Cannot serialize socket object", в целом логично

может кто-то извращается с передачей сессии БД между операторами, понимаю что может быть решение в виде упаковки в свой оператор

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