airflow - AWS Airflow 上的作业失败

Question

我最近开始研究 Amazon MWAA，并且能够设置环境并上传 DAG。当我尝试运行该作业时，它会失败而不会创建任何日志。 失败任务的快照

如果有人可以看一下，将不胜感激:)

下面是 DAG 代码：

from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta
from airflow.operators.sensors import TimeDeltaSensor
import boto3
import json

default_args = {
    'owner': 'AM',
    'start_date': datetime(2021, 3, 25) 
}


glue_client = boto3.client('glue', region_name='us-east-1')

def run_glue_job():
    glue_client.start_job_run(JobName='RunJob')  




with DAG('runglue', default_args=default_args, schedule_interval=timedelta(days=30)) as dag:
    rungluejob = PythonOperator(task_id='task1',python_callable=run_glue_job)
    

rungluejob

标签： airflowaws-gluemwaa