Function send_email

examples/celery_alternative/app.py:118–142

Send a single email. Celery equivalent: send_email.delay(to, subject, body) With async dirty client, this doesn't block the event loop! Other requests can be handled while waiting for the task.

(data: EmailRequest)

@app.post("/api/email/send")
async def send_email(data: EmailRequest):
    """
    Send a single email.

    Celery equivalent:
        send_email.delay(to, subject, body)

    With async dirty client, this doesn't block the event loop!
    Other requests can be handled while waiting for the task.
    """
    try:
        client = await get_dirty_client_async()
        result = await client.execute_async(
            EMAIL_WORKER,
            "send_email",
            to=data.to,
            subject=data.subject,
            body=data.body,
            html=data.html,
        )
        return result
    except DirtyTimeoutError:
        raise HTTPException(status_code=504, detail="Task timed out")
    except DirtyError as e:
        raise HTTPException(status_code=500, detail=str(e))


@app.post("/api/email/send-bulk")