vedimuthan opened a new issue #15435:
URL: https://github.com/apache/airflow/issues/15435
I have setup a simple dag to run ECS task via ECSOperator and I would like
to be notified when it fails. However, i am receiving approx. 25 emails per run
for the failures. Can you please tell me why this is happening?
from airflow import DAG
from airflow.contrib.operators.ecs_operator import ECSOperator
from datetime import datetime, timedelta
import json
from botocore.vendored import requests
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2019, 8, 16, 10, 0),
'email': ['xxxxxxxxxx.com'],
'email_on_failure': True,
}
dag = DAG('update_confluence', default_args=default_args,
schedule_interval="0 13 * * *")
t1 = ECSOperator(
task_id='xxxxxxx',
cluster='xxxxxxx',
launch_type='FARGATE',
task_definition='xxxxxx:1',
network_configuration={'awsvpcConfiguration':
{
'subnets': ['subnet-xxxxxxxx'],
'assignPublicIp': 'DISABLED'
}
},
overrides={},
region_name='us-east-1',
aws_conn_id="aws_default",
dag=dag)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
