@router.post("/leads/{lead_id}/re-analyze")
async def trigger_re_analysis(lead_id: int):
    # Trigger the background task pipeline starting at Task 1
    task_1_summary(lead_id)

    # Return a fragment that polls for status every 2 seconds
    return HTMLResponse(content=f"""
        <div hx-get="/leads/{lead_id}/analysis-status" 
             hx-trigger="every 2s" 
             hx-target="this" 
             hx-swap="outerHTML"
             class="animate-pulse">
            Analyzing...
        </div>
    """)