GB
День добрый, подскажите, можно каким либо простым образом выделить инстанс airwlow красной полоской, с обозначением, что это прод?
Size: a a a
2021 February 04
OI
День добрый, подскажите, можно каким либо простым образом выделить инстанс airwlow красной полоской, с обозначением, что это прод?
да
в конфиге
в конфиге
# Define the color of navigation bar
navbar_color = #007A87SG
Спасибо большое
SG
да
в конфиге
в конфиге
# Define the color of navigation bar
navbar_color = #007A87Благодарю
OI
День добрый, подскажите, можно каким либо простым образом выделить инстанс airwlow красной полоской, с обозначением, что это прод?
вообще, там при желании можно темы фласка накатывать
я даже как-то пытался ночную тему использовать
но все, кроме дефолтной, выглядят вырвиглазно
я даже как-то пытался ночную тему использовать
но все, кроме дефолтной, выглядят вырвиглазно
AB
Коллеги, добрый день.
Если в теле дага написать:
Я правильно понимаю, что подобные вещи нужно оборачивать в PythonOperator?
Если в теле дага написать:
if ....Мы получим зацикливание?
t1 = BashOperator(
task_id= 'create_file',
bash_command=create_command,
dag=dag
)
else ...
Я правильно понимаю, что подобные вещи нужно оборачивать в PythonOperator?
Если условие - дизайн-тайм (не зависит от результатов предыдущих операторов), то можно и как вы написали.
Если же ран-тайм, то похоже, что вы ищете BranchPythonOperator
Если же ран-тайм, то похоже, что вы ищете BranchPythonOperator
AB
Про зацикливание не понял.
VN
Если условие - дизайн-тайм (не зависит от результатов предыдущих операторов), то можно и как вы написали.
Если же ран-тайм, то похоже, что вы ищете BranchPythonOperator
Если же ран-тайм, то похоже, что вы ищете BranchPythonOperator
Алексей, условие в моем случае содержит проверку существования пути к файлу. В случае если путь есть даг выполняется, иначе exception.
Есть подозрение что конструкция описанная выше зацикливается и условие проверяется без остановки, даже если расписание у дага once или none.
Есть подозрение что конструкция описанная выше зацикливается и условие проверяется без остановки, даже если расписание у дага once или none.
AB
Да, условие проверяется постоянно.
Все даги пересоздаются раз в какое-то время, так устроен AF.
Все даги пересоздаются раз в какое-то время, так устроен AF.
PA
Может, параллельно что-то крутится, и таска в очереди. Или AF тормозит из-за чего-то.
Да там такая история. Это гугловый композер. Там только три таски которые уже выполнены. На момент рана. Но меня смущает то что там тайм ауты межу карент таской и даунстрим таской 2 минуты.
VN
Да, условие проверяется постоянно.
Все даги пересоздаются раз в какое-то время, так устроен AF.
Все даги пересоздаются раз в какое-то время, так устроен AF.
Может из-за этого быть загрузка ЦП на 100%?
Д
Всем привет.
Д
Кто-то пробовал запустить Airflow 2.0.0 с KubernetesExecutor?
Д
У меня под валится с ошибкой raise AirflowException(airflow.exceptions.AirflowException: dag_id could not be found: parallel_dag
Д
Нашел что-то подобное - но это сильно не помогло - github / helm/ charts/issues/22637
Д
Для запуска использую чарт со стейбла
Д
Все что меняю это
--set dags.gitSync.enabled=true \
--set dags.gitSync.repo=${dags_git_url} \
--set dags.gitSync.branch=${branch} \
--set dags.gitSync.subPath=dags
--set dags.gitSync.enabled=true \
--set dags.gitSync.repo=${dags_git_url} \
--set dags.gitSync.branch=${branch} \
--set dags.gitSync.subPath=dags
Д
Буду благодарен за помощь.
AB
Может из-за этого быть загрузка ЦП на 100%?
Майнить битки точно не стоит) Подробнее не скажу, не админ.