Как запланировать ежедневный запуск Airflow, включая сегодняшний день?Python

Программы на Python
Ответить
Anonymous
 Как запланировать ежедневный запуск Airflow, включая сегодняшний день?

Сообщение Anonymous »

Этот код, взятый из официальной документации, должен работать, но это не так, он пропускает сегодняшнее выполнение. Если в start_date я включаю вчерашнюю дату, если оно выполняется сегодня, но в интерфейсе мне ошибочно указывает дату, как если бы оно было выполнено вчера.
import pendulum
from airflow.models.dag import DAG
from airflow.operators.empty import EmptyOperator
from airflow.decorators import task, dag
from airflow.operators.python_operator import PythonOperator

with DAG(
dag_id="example",
schedule_interval='30 17 * * *',
start_date=pendulum.datetime(2024, 12, 6, 17, 20, tz="Europe/Madrid"),
catchup=False,
tags=["example3"],
) as dag:

def print_hello():
print('hello')

task1 = EmptyOperator(task_id="task1")
task2 = EmptyOperator(task_id="task2")
python_task = PythonOperator(
task_id='my_python_task',
python_callable=print_hello,
op_kwargs={'key': 'value'}
)
task1 >> task2 >> python_task


Подробнее здесь: https://stackoverflow.com/questions/792 ... ding-today
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «Python»