Simple task file

task.py

from app import mail, db
from celery.signals import task_postrun
from flask.ext.mail import Message
from app import create_celery_app
from celery.task.schedules import crontab
from celery.decorators import periodic_task
from celery.utils.log import get_task_logger
from datetime import datetime
import requests


celery = create_celery_app()
logger = get_task_logger(__name__)


@celery.task
def send_event_notification(*recepients):
	''' send mail to the recepients'''
	print "sent the mail"

@periodic_task(run_every=(crontab(hour="*", minute="*", day_of_week="*")))
def email_example():
    logger.info("Start task")
    now = datetime.now()
    #your code for sending mail
    print "sent the mail to subscriber"
    logger.info("Task finished: result = %i" % result)

@task_postrun.connect
def close_session(*args, **kwargs):
	db.session.remove()