apache-airflow-providers-celery
更新日志¶
3.9.0¶
注意
如 Apache Airflow 提供程序支持策略 中所述，此提供程序版本仅适用于 Airflow 2.9+。
其他¶
将 提供程序中 Airflow 的 最低 版本 提升 至 Airflow 2.9.0 (#44956)AIP-81 将 CLI 命令 移动 到 根据 混合、本地和远程 分类的 目录中 (#44538)从代码中 删除 AIP-44 配置 (#44454)
3.8.3¶
Bug 修复¶
所有 执行器 都应 继承自 BaseExecutor (#41904)在 Celery 任务 处理期间 删除 状态同步 (#41870)
其他¶
更改 导入 以 使用 标准 提供程序 的 BashOperator (#42252)
3.8.1¶
Bug 修复¶
修复: 'CeleryKubernetesExecutor' 和 'LocalKubernetesExecutor' 中缺少 'slots_occupied' (#41602)
3.8.0¶
注意
如 Apache Airflow 提供程序支持策略 中所述，此提供程序版本仅适用于 Airflow 2.8+。
其他¶
将 提供程序中 Airflow 的 最低 版本 提升 至 Airflow 2.8.0 (#41396)删除 已弃用的 SubDags (#41390)
3.7.2¶
Bug 修复¶
修复 异常类型 以包含 TypeError， 这 是 在 (#40012) 中引发的类型如果 在 _execute_in_fork 的 finally 块中 发生 异常 则捕获 sentry 刷新 (#40060)
其他¶
将 PID 和 返回代码 添加到 _execute_in_fork 日志记录中 (#40058)
3.7.1¶
其他¶
更快的 'airflow_version' 导入 (#39552)简化 'airflow_version' 导入 (#39497)ECS 执行器： 将 任务 设置为 RUNNING 状态， 一旦激活 (#39212)删除 2.7.0 的 兼容性 代码 - 现在 是 最低 Airflow 版本 (#39591)其他: 添加 关于 删除 未使用的代码 的 注释 (#39748)
3.7.0¶
注意
如 Apache Airflow 提供程序支持策略 中所述，此提供程序版本仅适用于 Airflow 2.7+。
其他¶
将 提供程序中 Airflow 的 最低 版本 提升 至 Airflow 2.7.0 (#39240)
3.6.2¶
Bug 修复¶
确保 在 装饰器上下文管理器中 调用 __exit__ (#38383)使用 内部 API 时， 不要 处置 sqlalchemy 引擎 (#38562)对于 Airflow < 2.8.0， 使用 Airflow 包 中的 Celery worker CLI (#38879)
其他¶
允许 使用 'redis'>=5 (#38385)AirflowOptionalProviderFeatureException 的重新引发 应为直接的 (#38555)
3.6.1¶
Bug 修复¶
从 celery 选项中 删除 pid 参数 以修复 重复 pid 问题， 将 celery 命令 移动 到 提供程序 包 (#36794)将 AirflowTaskTimeout 更改为 继承 BaseException (#35653)
其他¶
将 执行器 文档 迁移 到各自的 提供程序 (#37728)
3.6.0¶
功能¶
将 'task_acks_late' 配置 添加到 Celery 执行器 (#37066)
其他¶
改进 信息 以 防止 Celery 命令 自动缩放 配置错误 (#36576)
3.5.0¶
注意
如 Apache Airflow providers 支持策略 中所述，此提供程序版本仅适用于 Airflow 2.6+。
其他¶
将 providers 中 的 最低 Airflow 版本 提升至 Airflow 2.6.0 (#36017)
3.4.0¶
注意
如 Apache Airflow providers 支持策略 中所述，此提供程序版本仅适用于 Airflow 2.5+。
其他¶
提升 providers 的 最低 airflow 版本 (#34728)当 celery 传感器 引发 异常时 ，遵循 soft_fail 参数 (#34474)
3.3.4¶
Bug 修复¶
修复 celery 执行器中 update_task_state 的 条件 (#34192)
其他¶
合并 providers 中 相似的 if 逻辑 (#33987)通过 排除 5.3.2 和 5.3.3 来限制 celery (#34031)在 providers 中 将 try - except pass 替换为 contextlib.suppress (#33980)通过 将 某些 模块放入 类型检查块 ，改进 Airflow providers 中的 模块导入 (#33754)
3.3.3¶
Bug 修复¶
修复 Python 3.8 的 celery 和 opentelemetry 的依赖项 (#33579)
其他¶
使 身份验证管理器 提供其自己的 airflow CLI 命令 (#33481)将 Sqlalchemy 查询重构为 2.0 样式 (第 7 部分) (#32883)
3.3.2¶
其他¶
向 cncf.kubernetes 和 celery providers 添加缺少的 re2 依赖项 (#33237)在 Airflow 执行器中 将 State 替换为 TaskInstanceState (#32627)
3.3.0¶
注意
此提供程序版本是将 Celery 执行器和 Celery Kubernetes 执行器从核心 apache-airflow 包移动到 Celery 提供程序包的第一个版本。它还期望安装了 7.4.0+ 版本的 apache-airflow-providers-cncf-kubernetes 才能使用 CeleryKubernetesExecutor。 您可以使用 pip install apache-airflow-providers-celery[cncf.kubernetes] 安装带有 cncf.kubernetes 额外功能的提供程序，以获得正确版本的 cncf.kubernetes 提供程序安装。
特性¶
将 CeleryExecutor 移动到 celery 提供程序 (#32526)为 旧的 providers 添加 pre-Airflow-2-7 硬编码的 config 默认值 (#32775)[AIP-51] 执行器 提供 CLI 命令 (#29055)
其他¶
将 所有 k8S 类移动到 cncf.kubernetes 提供程序 (#32767)添加 执行器发现和文档 (#32532)将 default_celery.py 移动到 提供程序内部 (#32628)在 执行器的 CLI 提供中 引发原始导入错误 (#32931)
3.2.0¶
注意
如 Apache Airflow providers 支持策略 中所述，此提供程序版本仅适用于 Airflow 2.4+。
其他¶
提升 providers 中 的 最低 Airflow 版本 (#30917)
3.1.0¶
注意
如 Apache Airflow providers 支持策略 中所述，此提供程序版本仅适用于 Airflow 2.3+。
其他¶
将 所有 providers 的 最低 airflow 版本 移动到 2.3.0 (#27196)
3.0.0¶
重大更改¶
注意
如 Apache Airflow providers 支持策略 中所述，此提供程序版本仅适用于 Airflow 2.2+。
2.0.0¶
重大更改¶
自动应用 apply_default 装饰器 (#15667)
警告
由于移除了 apply_default 装饰器，此版本的提供程序需要 Airflow 2.1.0 或更高版本。如果您的 Airflow 版本低于 2.1.0，并且您想安装此提供程序版本，请先将 Airflow 升级到至少 2.1.0 版本。否则，您的 Airflow 包版本将自动升级，您必须手动运行 airflow upgrade db 来完成迁移。
1.0.1¶
更新了文档和自述文件。
1.0.0¶
提供程序的初始版本。