Function generate

examples/celery_alternative/app.py:157–169

()

    With dirty arbiters, progress is streamed in real-time!
    """
    async def generate():
        try:
            client = await get_dirty_client_async()
            async for progress in client.stream_async(
                EMAIL_WORKER,
                "send_bulk_emails",
                recipients=data.recipients,
                subject=data.subject,
                body=data.body,
            ):
                yield f"data: {json.dumps(progress)}\n\n"
        except DirtyError as e:
            yield f"data: {json.dumps({'error': str(e)})}\n\n"

    return StreamingResponse(
        generate(),