英文: Airflow: is there a way to "clear all failed runs"? 问题 在我的Airflow GUI中,我看到: 大量的运行失败是因为...
新的 @task 装饰器在 Airflow 中是否可以用来实现回调?
英文: can callbacks be implemented with the new @task decorator in airflow 问题 Airflow提供了任务成功和失败的任务回调示例...
Airflow:如何强制重新解析DAG定义文件
英文: Airflow: how to force reparse of DAG definition file 问题 有没有办法在Airflow中强制重新解析DAG定义文件?所有DAG定义文件都可以...
PydanticUserError: 在Airflow数据库初始化命令中检测到了未注释的属性
英文: PydanticUserError: A non-annotated attribute was detected in Airflow db init command 问题 我正在尝试在我的...
Airflow触发规则,除一个外都已成功。
英文: Airflow trigger rule, all but one has succeeded 问题 Airflow中是否有触发规则(或自定义规则),当除一个上游任务仍在运行以外,所有其他上游...
ModuleNotFoundError: 在Airflow中找不到模块名称 ‘gspread’
英文: ModuleNotFoundError: No module named 'gspread' in Airflow 问题 You are encountering a &quo...
如何从KubernetesPodOperator返回数据
英文: How to return data from KubernetesPodOperator 问题 在DAG脚本中: result = KubernetesPodOperator( task_i...
将文件从S3位置复制/移动到通过Airflow DAG挂载在EC2上的EBS。
英文: Copy/Move files from S3 location to EBS mounted on EC2 via airflow DAG 问题 我有一个Airflow DAG。我想通过DA...
无法连接到在Docker上本地运行的GCP Airflow。
英文: unable to connect to GCP running Airflow locally on docker 问题 我正在本地在Docker上运行Airflow,尝试通过Admin&g...
创建具有独立依赖关系的动态Airflow任务。
英文: Create Dynamic Airflow tasks with separate dependencies 问题 我想在循环中生成多个Airflow传感器/操作器,但我希望能够逐个访问它们...
9