MM
А что там написать, есть пример?
Если хочу чтобы разница интервалов в пару часов допустима
Если хочу чтобы разница интервалов в пару часов допустима
Size: a a a
2021 October 13
MM
2021 October 14
I
Она не delta, она date
Вот в тесте пример
https://github.com/apache/airflow/blob/main/tests/sensors/test_external_task_sensor.py#L321
Для твоего примера получается будет типа
Вот в тесте пример
https://github.com/apache/airflow/blob/main/tests/sensors/test_external_task_sensor.py#L321
Для твоего примера получается будет типа
lambda dt: dt + timedelta(hours=2)
ДН
из того что я видел - обычно это легкие лямбды
если не ошибаюсь на вход в Callable приходит execution_date в Pendulum формате, и дальше просто работаешь с ним
lambda dt: dt.start_of('month')если не ошибаюсь на вход в Callable приходит execution_date в Pendulum формате, и дальше просто работаешь с ним
FZ
Приветствую! Подскажите, кто чем пользуется для соединения airflow и oracle. Н-р, OracleOperator, hooks и т.д ? И что лучше использовать?
FZ
Или может встречали инструкцию по соединению Oracle и airflow в docker
R
на нижнем уровне работает oracle tns client, выше него cx_oracle, над ним можно создать свои hooks, operators
MM
Execution_date должны совпадать?
MM
А можно сделать чтобы не совпадали?
Пример, даг зашедуленный на 3 ночи и следующий потом на 5 ночи или это дичь и просто нужно ставить одинаковые?
Просто как будто я через эти дельты должен прям подстраивать всё друг под друга неудобно
Можно ли просто зависимость на последний даг ран без запар😂
Пример, даг зашедуленный на 3 ночи и следующий потом на 5 ночи или это дичь и просто нужно ставить одинаковые?
Просто как будто я через эти дельты должен прям подстраивать всё друг под друга неудобно
Можно ли просто зависимость на последний даг ран без запар😂
ME
у меня лямбды делают проверку месячных запусков из квартального
ME
вот да)
ME
если время такое в целевом даге есть, его и проверит
MM
Да вот нет
Я через дельту должен подобрать её так, чтобы точно попасть в execution date
Я через дельту должен подобрать её так, чтобы точно попасть в execution date
MM
То есть если разница 2 часа 10 минут, то я должен выставить 2 часа 10 минут, а 3 часа не катит
Это так и работает или я налажал и стоит перепроверить?)
Это так и работает или я налажал и стоит перепроверить?)