Блог

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

Я новичок в airflow, не уверен, почему происходит такое поведение.

Прикрепляем скриншот также под кодом.

 from airflow.operators import BashOperator
from datetime import datetime, timedelta
from pendulum import timezone

local_tz = timezone("Asia/Dubai")
# Following are defaults which can be overridden later on
default_args = {
    'owner': 'User',
    'depends_on_past': False,
    'start_date': datetime(2016, 4, 15,tzinfo=local_tz)
}

dag = DAG('Helloworld',schedule_interval='0 17 * * *', default_args=default_args,catchup=False)


t1 = BashOperator(
    task_id='task_1',
    bash_command='echo "Hello World from Task 1"',
    dag=dag)

t1
  

Написав schedule_interval=None, он будет работать только один раз, и такое поведение видно, потому что airflow работает в 24-часовом окне, пока не будет достигнуто 24-часовое окно для даты выполнения, dag не будет запущен.