prefect 2.0 的 flow 和 task 必须显式调用才能执行,定义阶段仅注册对象不运行逻辑,运行需调用 my_flow() 或 my_flow.serve(),部署需 prefect deploy ./script.py:flow_name,docker 镜像需版本匹配且含完整依赖。

Prefect 2.0 的 flow 和 task 必须显式调用才能执行
很多人写完 @flow 和 @task 装饰的函数,直接运行脚本却没任何输出——不是代码错了,是 Prefect 2.0 不再自动触发执行。它把“定义”和“运行”彻底分开。
- 定义阶段:只注册对象(
Flow、Task),不执行任何逻辑 - 运行阶段:必须显式调用
my_flow()或my_flow.serve(),或通过prefect deploy提交到服务器 - 本地调试时最简方式就是直接加一行
my_flow()在文件末尾;漏掉这行,等于写了张菜谱但从不下锅 - 注意:在 Jupyter 中多次运行同一 cell 可能导致
Flow重复注册报错ValueError: Flow with name 'xxx' already exists,建议每次重载模块或重启 kernel
部署时 prefect deploy 找不到 flow 的常见原因
prefect deploy 命令依赖 Python 模块路径和函数全名,不是靠当前工作目录或文件名猜的。
- 确保目标 flow 函数在模块顶层(不能嵌套在 if/else 或函数内部)
- 命令格式必须是
prefect deploy ./my_script.py:my_flow,中间用英文冒号分隔路径和函数名 - 如果脚本依赖相对导入(比如
from .utils import helper),prefect deploy会失败——它用的是模块加载机制,不是直接 exec,所以推荐改用绝对导入或把共用代码打成包 - Windows 下路径斜杠方向不影响,但文件扩展名
.py不能省略
State 类型和 return 值的关系容易被误解
Prefect 2.0 的 task 返回值默认包装成 State 对象,但你写的 return "done" 不会变成失败态,也不会自动重试——除非你主动 raise 异常或调用 raise FAILED("reason")。
华友协同办公管理系统(华友OA),基于微软最新的.net 2.0平台和SQL Server数据库,集成强大的Ajax技术,采用多层分布式架构,实现统一办公平台,功能强大、价格便宜,是适用于企事业单位的通用型网络协同办公系统。 系统秉承协同办公的思想,集成即时通讯、日记管理、通知管理、邮件管理、新闻、考勤管理、短信管理、个人文件柜、日程安排、工作计划、工作日清、通讯录、公文流转、论坛、在线调查、
- 正常返回任意 Python 对象(
str、dict、None)都会被转为Completed状态,下游 task 收到的是解包后的值,不是State - 想让 task 显式失败,得
raise Exception("boom")或raise prefect.exceptions.Abort("stop now"),而不是return Failed(...) - 使用
return_state=True参数调用 task(如my_task.submit(return_state=True))才会真正拿到State实例,日常链式调用不用管它 - 日志里看到
Finished in state Completed(message="All states completed.", type=COMPLETED)是正常收尾,不是 warning
Docker 部署时 prefect.yaml 的 image 和 pull_policy 配置陷阱
本地测试通过的 flow,一上 Docker 就报 ModuleNotFoundError,大概率是镜像里没装你的包,或者装了但版本不对。
立即学习“Python免费学习笔记(深入)”;
-
image字段填的是构建后的镜像名+tag,比如myorg/myflow:1.2,不是 Dockerfile 路径 -
pull_policy默认是IfNotPresent,CI/CD 流水线里如果复用 tag(如 always use:latest),旧镜像可能被跳过拉取——建议用 commit hash 或日期戳做 tag - 镜像构建时,
requirements.txt必须包含prefect>=2.0,且版本要和本地开发一致;否则flow定义语法可能不兼容(例如 2.11+ 的log_prints=True在 2.9 会报错) - 别在
Dockerfile里用COPY . /opt/prefect然后期望prefect deploy自动识别——部署命令不管容器里怎么组织文件,只认你传给它的 Python 模块路径









