tasks_2.py

import os
import time

from celery import Celery

app = Celery('tasks', broker=os.getenv('BROKER_URL', 'redis://localhost/0'))

@app.task
def envia_email():
  ...

app.conf.beat_schedule = {
    'envia-emails-a-cada-30-segundas': {
        'task': 'tasks.envia_email',
        'schedule': 10.0,
    }
}