0

0

Python Prefect 2.0 的现代工作流实践

冷炫風刃

冷炫風刃

发布时间:2026-02-24 21:00:02

|

130人浏览过

|

来源于php中文网

原创

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

python prefect 2.0 的现代工作流实践

Prefect 2.0 的 flowtask 必须显式调用才能执行

很多人写完 @flow@task 装饰的函数,直接运行脚本却没任何输出——不是代码错了,是 Prefect 2.0 不再自动触发执行。它把“定义”和“运行”彻底分开。

  • 定义阶段:只注册对象(FlowTask),不执行任何逻辑
  • 运行阶段:必须显式调用 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系统
华友协同办公自动化OA系统

华友协同办公管理系统(华友OA),基于微软最新的.net 2.0平台和SQL Server数据库,集成强大的Ajax技术,采用多层分布式架构,实现统一办公平台,功能强大、价格便宜,是适用于企事业单位的通用型网络协同办公系统。 系统秉承协同办公的思想,集成即时通讯、日记管理、通知管理、邮件管理、新闻、考勤管理、短信管理、个人文件柜、日程安排、工作计划、工作日清、通讯录、公文流转、论坛、在线调查、

下载
  • 正常返回任意 Python 对象(strdictNone)都会被转为 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.yamlimagepull_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 模块路径
Prefect 2.0 的 flow 注册、运行、部署三步之间边界很清晰,但每步的触发条件和隐含依赖比 1.x 更多。最容易卡住的地方不是语法,而是“以为它该自动做某事”,结果发现得手动补调用、补路径、补镜像 tag。

相关文章

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

829

2023.08.22

windows查看端口占用情况
windows查看端口占用情况

Windows端口可以认为是计算机与外界通讯交流的出入口。逻辑意义上的端口一般是指TCP/IP协议中的端口,端口号的范围从0到65535,比如用于浏览网页服务的80端口,用于FTP服务的21端口等等。怎么查看windows端口占用情况呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

1256

2023.07.26

查看端口占用情况windows
查看端口占用情况windows

端口占用是指与端口关联的软件占用端口而使得其他应用程序无法使用这些端口,端口占用问题是计算机系统编程领域的一个常见问题,端口占用的根本原因可能是操作系统的一些错误,服务器也可能会出现端口占用问题。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

1153

2023.07.27

windows照片无法显示
windows照片无法显示

当我们尝试打开一张图片时,可能会出现一个错误提示,提示说"Windows照片查看器无法显示此图片,因为计算机上的可用内存不足",本专题为大家提供windows照片无法显示相关的文章,帮助大家解决该问题。

823

2023.08.01

windows查看端口被占用的情况
windows查看端口被占用的情况

windows查看端口被占用的情况的方法:1、使用Windows自带的资源监视器;2、使用命令提示符查看端口信息;3、使用任务管理器查看占用端口的进程。本专题为大家提供windows查看端口被占用的情况的相关的文章、下载、课程内容,供大家免费下载体验。

460

2023.08.02

windows无法访问共享电脑
windows无法访问共享电脑

在现代社会中,共享电脑是办公室和家庭的重要组成部分。然而,有时我们可能会遇到Windows无法访问共享电脑的问题。这个问题可能会导致数据无法共享,影响工作和生活的正常进行。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2361

2023.08.08

windows自动更新
windows自动更新

Windows操作系统的自动更新功能可以确保系统及时获取最新的补丁和安全更新,以提高系统的稳定性和安全性。然而,有时候我们可能希望暂时或永久地关闭Windows的自动更新功能。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

854

2023.08.10

windows boot manager
windows boot manager

windows boot manager无法开机的解决方法:1、系统文件损坏,使用Windows安装光盘或USB启动盘进入恢复环境,选择修复计算机,然后选择自动修复;2、引导顺序错误,进入恢复环境,选择命令提示符,输入命令"bootrec /fixboot"和"bootrec /fixmbr",然后重新启动计算机;3、硬件问题,使用硬盘检测工具进行扫描和修复;4、重装操作系统。本专题还提供其他解决

1898

2023.08.28

Golang 生态工具与框架:扩展开发能力
Golang 生态工具与框架:扩展开发能力

《Golang 生态工具与框架》系统梳理 Go 语言在实际工程中的主流工具链与框架选型思路,涵盖 Web 框架、RPC 通信、依赖管理、测试工具、代码生成与项目结构设计等内容。通过真实项目场景解析不同工具的适用边界与组合方式,帮助开发者构建高效、可维护的 Go 工程体系,并提升团队协作与交付效率。

1

2026.02.24

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 22.4万人学习

Django 教程
Django 教程

共28课时 | 4.5万人学习

SciPy 教程
SciPy 教程

共10课时 | 1.7万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号