Apache Airflow共2篇
用 dag.test() 调试 Airflow DAG,并明确真实执行的边界-未完纪

用 dag.test() 调试 Airflow DAG,并明确真实执行的边界

为 DAG 增加本地调试入口,按任务 ID 跳过等待和清理步骤,并使用 pdb 或 IDE 断点检查执行过程。
彩雨伞的头像-未完纪钻石会员彩雨伞4小时前
0420
用 Apache Airflow 编排 Polars Cloud 查询:并行任务、中间结果与集群清理-未完纪

用 Apache Airflow 编排 Polars Cloud 查询:并行任务、中间结果与集群清理

从服务账户和单查询提交开始,用命名manifest并行计算,通过Parquet位置连接多个阶段,并区分任务结束、查询终态和安全关停。
彩雨伞的头像-未完纪钻石会员彩雨伞5小时前
0280