Airflow DAG因JSONDecodeError而中断

cnjp1d6j  于 12个月前  发布在  其他
关注(0)|答案(1)|浏览(151)

所以我的DAG开始如下:

import airflow
from datetime import timedelta, datetime
from airflow import DAG
from airflow.models import Variable
from airflow.contrib.operators.bigquery_operator import BigQueryOperator

default_args = {
"owner": "scheduled_queries",
"depends_on_past": False,
"start_date": airflow.utils.dates.days_ago(1),
"email": Variable.get("email"),
"email_on_failure": True,
"email_on_retry": True,
"retries": 0,
"retry_delay": timedelta(minutes=1),
}

dag = DAG('scheduled_queries',
schedule_interval=None, #'0 0 * * *',
#template_searchpath=tmpl_search_path,
default_args=default_args
)

字符串
我得到的错误是:

"
Broken DAG (dags/testdag.py):
Traceback (most recent call last):
  File "/opt/python3.8/lib/python3.8/json/decoder.py", line 337, in decode
    obj, end = self.raw_decode(s, idx=_w(s, 0).end())
  File "/opt/python3.8/lib/python3.8/json/decoder.py", line 353, in raw_decode
    obj, end = self.scan_once(s, idx)
json.decoder.JSONDecodeError: Expecting property name enclosed in double quotes: line 1 column 1 (char 263)
"


我不知道为什么会发生这种情况。因为相同的DAG在其他环境中工作得很好,如UAT。请指导我的问题和解决方案。提前感谢!

kh212irz

kh212irz1#

如果其他人遇到这个问题,我们在我们的一个环境中遇到了类似的问题,这个问题可以追溯到我们的一个变量中的无效JSON(打字错误)。就像在UI中的全局Airflow Variables选项卡中一样。

相关问题