Apache Airflow 2.2.1 发布，Airbnb 开源的调度系统

Apache Airflow 2.2.1  已正式发布，Airflow 是一个灵活、可扩展的工作流自动化和调度系统，可编集和管理数百 PB 的数据流。项目可轻松编排复杂的计算工作流，通过智能调度、数据库和依赖关系管理、错误处理和日志记录，Airflow 可以对从单个服务器到大规模集群的资源进行自动化管理。Airflow 采用 Python 编写，具有高扩展性，能够运行其他语言编写的任务，并允许与常用的体系结构和项目集成，如 AWS S3、Docker、Kubernetes、MySQL、PostgresSQL 等。

主要更新内容

• 修复调度程序中的意外提交错误
• 添加 DagRun.logical_date 作为属性
• 任务完成时清除 ti.next_method 和 ti.next_kwargs
• 更快的 PostgreSQL 数据库迁移到 Airflow 2.2
• 删除 Swagger2Specification._set_defaults 类方法中不正确的类型注释
• 将 TriggererJob 添加到作业检查命令
• 当下一次运行为 None 时隐藏工具提示
• 使用数据间隔兼容层创建 TI 上下文 
• 修复排队的 dag 运行更改 catchup=False 行为
• 当 dag 或任务完成时，将详细信息添加到日志记录中
• 警告不支持的 Python 3.10 
• 通过使用 max_active_runs 限制排队的 dagrun 创建来修复追赶 
• 缺少序列化 dag 时防止调度程序崩溃 
• 不要为其他数据库安装 SQLAlchemy/Pendulum 适配器
• 解决方法 libstdcpp TLS 错误
• 将 ds、ts 等改回使用逻辑日期
• 确保任务状态在标记为失败/成功/跳过时不会改变 
• 将触发器页面标签重命名为逻辑日期 
• 允许 Param 支持默认值 None
• 从数据库反序列化时升级旧的 DAG/任务参数格式
• 不要将 ENV 和 _cmd 烘焙到非 sudo 的 tmp 配置中 
• CLI：如果缺少 args，则在加载 DAG 之前回填命令失败 
• 错误修复：插入到 task_fail 时空执行日期违反 NOT NULL 
• 尝试在 upgradeb 中移动 "悬空" 行
• SchedulerJob._process_executor_events 中的行锁 TI 查询 
• 修复 Airflow 2.2.0 中的 XCom.delete 错误 
• 在启动触发器之前检查 python 版本

详情请查看更新公告。