Ошибка планировщика Cloud Composer при добавлении первого знака

Question

У меня работает DAG на локальном Airflow.Я запустил Cloud Composer и хотел перенести туда свои DAG.При добавлении первого файла DAG планировщик показывает эту ошибку:

Traceback (последний вызов был последним): файл "/usr/local/lib/airflow/airflow/models.py", строка 363,в файле процесса m = imp.load_source (mod_name, filepath) Файл "/usr/local/lib/python3.6/imp.py", строка 172, в модуле load_source = _load (spec) файл "", строка 684, в _loadФайл "", строка 665, в _load_unlocked файле "", строка 674, в файле exec_module "", строка 781, в файле get_code "", строка 741, в файле source_to_code "", строка 219, в файле _call_with_frames_removed "/ home /airflow / gcs / dags / testdag.py ", строка 95 'start_date': datetime (2018, 12, 05),

Это строка 95:

args = {
    'owner': 'Airflow',
    'start_date': datetime(2018, 12, 05),
    'retries': 5,
    'retry_delay': timedelta(minutes=5)
}

Никогдасталкивался с этой ошибкой раньше.

Answer 1

Если вы хотите запустить группу обеспечения доступности баз данных и выполнить поиск по историческим датам, тогда вы указываете прошедшие даты как start_date

Попробуйте задать

from datetime import datetime, timedelta

args = {
    'owner': 'Airflow',
    'provide_context': True,
    'depends_on_past': False,
    'start_date': datetime.combine(datetime.today(),datetime.min.time()),
    'retries': 5,
    'retry_delay': timedelta(minutes=5)
}