#############
from airflow import DAG from airflow.operators.bash_operator import BashOperator from airflow.operators.python_operator import PythonOperator from airflow.operators.email_operator import EmailOperator from airflow.utils.email import send_email_smtp import datetime as dt default_args = { 'owner': 'arflow', 'depends_on_past': False, 'start_date': dt.datetime(2018, 10, 30), 'email':['****@gmail.com'], 'email_on_failure': True, 'email_on_retry': False, #'retries': 1, #'retry_delay': timedelta(minutes=5), } dag = DAG('Raja's Airflow', default_args=default_args, schedule_interval='0 3 * * *') notify_email = EmailOperator(task_id='email',to=['****@gmail.com'],subject="HI",html_content="raw content #2",dag=dag) t1 = BashOperator(task_id='load_data', bash_command='python3 /usr/share/airflow/documents/scripts/Airflow-Testing/arfotest.py',email_on_failure = notify_email,dag=dag) t1 ########### Content of .cfg file smtp_host = Smtp.live.com smtp_starttls = True smtp_ssl = False smtp_user = *** smtp_password= **** smtp_port = 587 smtp_mail_from=***(same as stmp_user) ################## This is the error, I'm getting it [2018-11-01 11:18:56,405] {models.py:1769} ERROR - [Errno 111] Connection refused Traceback (most recent call last): File "/usr/local/lib/python2.7/dist-packages/airflow/models.py", line 1766, in handle_failure self.email_alert(error, is_retry=False) File "/usr/local/lib/python2.7/dist-packages/airflow/models.py", line 1945, in email_alert send_email(task.email, title, body) File "/usr/local/lib/python2.7/dist-packages/airflow/utils/email.py", line 53, in send_email mime_subtype=mime_subtype, mime_charset=mime_charset, **kwargs) File "/usr/local/lib/python2.7/dist-packages/airflow/utils/email.py", line 99, in send_email_smtp send_MIME_email(SMTP_MAIL_FROM, recipients, msg, dryrun) File "/usr/local/lib/python2.7/dist-packages/airflow/utils/email.py", line 119, in send_MIME_email s = smtplib.SMTP_SSL(SMTP_HOST, SMTP_PORT) if SMTP_SSL else smtplib.SMTP(SMTP_HOST, SMTP_PORT) File "/usr/lib/python2.7/smtplib.py", line 256, in __init__ (code, msg) = self.connect(host, port) File "/usr/lib/python2.7/smtplib.py", line 317, in connect self.sock = self._get_socket(host, port, self.timeout) File "/usr/lib/python2.7/smtplib.py", line 292, in _get_socket return socket.create_connection((host, port), timeout) File "/usr/lib/python2.7/socket.py", line 575, in create_connection raise err error: [Errno 111] Connection refused