Source code for airflow.operators.email_operator

# -*- coding: utf-8 -*-
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

from airflow.models import BaseOperator
from import send_email
from airflow.utils.decorators import apply_defaults

[docs]class EmailOperator(BaseOperator): """ Sends an email. :param to: list of emails to send the email to. (templated) :type to: list or string (comma or semicolon delimited) :param subject: subject line for the email. (templated) :type subject: string :param html_content: content of the email, html markup is allowed. (templated) :type html_content: string :param files: file names to attach in email :type files: list :param cc: list of recipients to be added in CC field :type cc: list or string (comma or semicolon delimited) :param bcc: list of recipients to be added in BCC field :type bcc: list or string (comma or semicolon delimited) :param mime_subtype: MIME sub content type :type mime_subtype: string :param mime_charset: character set parameter added to the Content-Type header. :type mime_charset: string """ template_fields = ('to', 'subject', 'html_content') template_ext = ('.html',) ui_color = '#e6faf9' @apply_defaults def __init__( self, to, subject, html_content, files=None, cc=None, bcc=None, mime_subtype='mixed', mime_charset='us_ascii', *args, **kwargs): super(EmailOperator, self).__init__(*args, **kwargs) = to self.subject = subject self.html_content = html_content self.files = files or [] = cc self.bcc = bcc self.mime_subtype = mime_subtype self.mime_charset = mime_charset def execute(self, context): send_email(, self.subject, self.html_content, files=self.files,, bcc=self.bcc, mime_subtype=self.mime_subtype, mime_charset=self.mime_charset)