Function run_cleanup

examples/celery_alternative/app.py:358–370

Run cleanup task (normally triggered by cron).

(data: CleanupRequest = CleanupRequest())

@app.post("/api/scheduled/cleanup")
async def run_cleanup(data: CleanupRequest = CleanupRequest()):
    """Run cleanup task (normally triggered by cron)."""
    try:
        client = await get_dirty_client_async()
        result = await client.execute_async(
            SCHEDULED_WORKER,
            "cleanup_old_files",
            directory=data.directory,
            max_age_days=data.max_age_days,
        )
        return result
    except DirtyError as e:
        raise HTTPException(status_code=500, detail=str(e))


@app.post("/api/scheduled/daily-report")