为什么 API 不执行循环任务 - FastAPI、Celery？

Question

我有一个 API，负责根据传递给它的地址构建数据库模型。这样的模型有数百个，我不想手动完成，因此我决定创建一个 API，在调用该 API 时，它将循环遍历所有地址并将它们传递给构建模型。

我使用： FastAPI、Celery

Celery 任务

from agents.walletReputation import WalletReputation

@app.task(name="walletReputation")
def wallet_reputation(id: str):
    WalletReputation(id).add_reputation_to_db()

    return {"message": "Success"}

生成器从 FB 生成项目

def all_addresses_generator():
    for row in session.query(DbNcTransaction).all():
        yield row

我的端点

# Make or update one wallet
@router.post("/run/{id}")
async def create_or_update(id: str):
    wallet_reputation.delay(id)

    return {"Status": "Task successfully add to execute"}

# Make or update all wallets
@router.post("/run/all")
async def create_or_update_all():
    for address in all_addresses_generator():
        wallet_reputation.delay(address)

    return {"Status": "Task successfully add to execute"}

你知道为什么吗第一个端点有效，而第二个端点不再有效？