OI
Понял, спасибо большое)
Size: a a a
2021 February 05
OI
Коллеги добрый день. А как получить доступ к execution_date в самом начале файла дага? через что? мне надо проанализировать час запуска и уже исходя из этого передавать в таски шаблоны для date_from, date_to
ну это нельзя в коде дага получить
это надо в параметрах или коде самого таска
это надо в параметрах или коде самого таска
ФЧ
Ребят не напомните какая настройка отвечает за одновременное кол-во запущенных тасков в даге?
マサ
concurrency вроде?
А
ну это нельзя в коде дага получить
это надо в параметрах или коде самого таска
это надо в параметрах или коде самого таска
тогда не очень красиво получиться. в таск попадут одни даты, и будут в свойствах таска показываться в rendered. а селекты по факту будут с другими параметрами.
OI
тогда не очень красиво получиться. в таск попадут одни даты, и будут в свойствах таска показываться в rendered. а селекты по факту будут с другими параметрами.
можно параметризовать даты (шаблоны jinja)и как раз передавать нужные даты через параметры
будет и в rendered нормально
будет и в rendered нормально
ФЧ
concurrency вроде?
верно
А
можно параметризовать даты (шаблоны jinja)и как раз передавать нужные даты через параметры
будет и в rendered нормально
будет и в rendered нормально
так мне и надо их до передачи в таск определить в зависимости от часа запуска
OI
так мне и надо их до передачи в таск определить в зависимости от часа запуска
это можно делать в самом шаблоне
OI
в даге это сделать не получится
AS
Коллеги добрый день. А как получить доступ к execution_date в самом начале файла дага? через что? мне надо проанализировать час запуска и уже исходя из этого передавать в таски шаблоны для date_from, date_to
Можно посмотреть в сторону branching через переменные xcom
А
Можно посмотреть в сторону branching через переменные xcom
Это как? Можно подробнее? Я уже сделал через if else jinja. Но другие способы тоже полезно будет знать
OI
Это как? Можно подробнее? Я уже сделал через if else jinja. Но другие способы тоже полезно будет знать
PythonBranchOperator
А
PythonBranchOperator
ааа. все, понял, спасибо.
AS
Это как? Можно подробнее? Я уже сделал через if else jinja. Но другие способы тоже полезно будет знать
Статья про дни недели, но я переделывал под часы запуска: https://medium.com/@guillaume_payen/use-conditional-tasks-with-apache-airflow-98bab35f1846
