Prefect流部署本地运行报错‘Deployment not found’，如何实现流依次执行？

可能原因及修复步骤 #

1. 核对部署名称的准确性 #

run_deployment的name参数格式必须严格遵循[命名空间/]<flow名称>/<部署名称>，你可以通过以下命令查看所有已注册的部署，确认目标部署的准确名称：

prefect deployment ls

找到flow2对应的部署条目，复制其完整的Name字段，替换到run_deployment的参数中。

2. 确认目标部署已完成注册 #

确保flow2的部署已经通过prefect deployment apply命令完成注册：

# 假设你的flow2部署配置文件是flow2_deployment.yaml
prefect deployment apply flow2_deployment.yaml

执行后会输出部署成功的提示，确认目标部署已被添加到Prefect系统中。

3. 检查Flow名称是否匹配 #

如果flow2的@flow装饰器没有显式指定name参数，Flow的默认名称是函数名，而非你自定义的flow2_name。比如：

# 未指定name，Flow名称为flow2
@flow
def flow2():
    pass

# 显式指定name，Flow名称为flow2_name
@flow(name="flow2_name")
def flow2():
    pass

确保run_deployment中使用的Flow名称与实际定义一致。

4. 确认代理处于运行状态 #

本地运行时，必须启动Prefect代理才能执行部署任务：

prefect agent start

代理启动后会持续监听任务队列，确保flow1触发的flow2部署能被执行。

修正后的示例代码 #

假设通过prefect deployment ls查到flow2的部署名称为flow2_name/deployment_flow2_name，且已完成注册，代码可保持不变，但需确保上述步骤都已完成。如果名称有误，修正为实际名称即可：

@flow
def flow1_actions():
    run_deployment(name="实际_flow名称/实际_部署名称")

内容的提问来源于stack exchange，提问作者Craciun Bogdan