获取“无法启动系统任务系统任务”-Airflow DAG / SQL Server

问题描述

我触发并刷新了dag任务后，它从运行，延迟到失败。来自气流的错误日志告诉我检查来自sql server的错误，当我检查sql server docker容器上的日志时得到“无法启动系统任务System Task”。我不确定是否需要指定架构，但其余连接参数是否正确。

[entrypoint.sh]

"${AIRFLOW_CONN_MY_SRC_DB:=mssql+pyodbc://SA:P@SSW0RD@mssqlcsc380:1433/?driver=ODBC+Driver+17+for+sql+Server}"

[dag.py]

with DAG (
    'mssql_380_dag',start_date=days_ago(1),schedule_interval=None,catchup=False,default_args={
        'owner' : 'me','retries' : 1,'retry_delay' : dt.timedelta(minutes=5)
        }
    ) as dag:
    get_requests = MssqlOperator(
        task_id = 'get_requests',mssql_conn_id = 'my_src_db',sql = 'select * from Request',dag = dag
    )

解决方法

问题只是它无法注意到表，所以我指定了解决该问题的数据库，即使由于我已经在连接字符串上传递了该数据库，该数据库也应被识别。

sql = 'use csc380db; select * from Request',