tasks.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():
    lista_de_usuarios = [
        'Monica',
        'Cebolinha',
        'Magali',
        'Cascão',
        'Louco',
        'Tina',
        'Rolo',
    ]

    for usuario in lista_de_usuarios:
        print(f'Enviando email para {usuario}...')
        time.sleep(1)
        print(f'Email enviando para {usuario}!')