示例日期尝试将execution_date参数保存为空

Question

从气流2.0.1升级到2.1.0后，我有一个问题。当我运行样本日，它失败了，我无法保存一行在task_fail表。

ERROR: null value in column "execution_date" violates not-null constraint

from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.python import PythonOperator
from test_methods import test_python_method, test_python_log
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'retries': 1,
'retry_delay': timedelta(minutes=5)
}
with DAG(
'Sample-Dag',
default_args=default_args,
start_date= datetime(2021, 1, 1),
schedule_interval=timedelta(minutes=10),
catchup=False,
) as dag:
task_1 = PythonOperator(
task_id='Task-1',
python_callable=test_python_method,
)
task_2 = PythonOperator(
task_id='Task-2',
python_callable=test_python_log,
)
task_1 >> task_2

如果有帮助的话，我可以添加config，但这可能是因为Dag结构。

Answer 1

我想你可能没有做过airflow db upgrade。

您必须在迁移到较新的气流版本后运行此操作。