mailasync.py

import yagmail
from celery import Celery
from default_settings import *
import time

celery = Celery(
        'mailasync',
        broker='pyamqp://guest@localhost//'
    )

mail = yagmail.SMTP(MAIL_USERNAME, MAIL_PASSWORD)

@celery.task()
def sendMail(data):
    
    ''' simulate long-running task'''
    time.sleep(5.0)

    ''' send email '''
    receiver=data['to']
    contents = ["Celery is awesome!"]
    mail.send(receiver, 'Sent from a worker', contents)