airflow

英文: How to run some batch script on all MWAA Airflow worker nodes? 问题 有没有办法在MWAA启动的每个工作节点上运行特定的批处理脚本...

英文: How to use a python list as global variable python list with in @task.external_python? 问题 以下是您要的...

英文: how to create a chain of dynamic tasks? 问题 我尝试创建一个动态任务链的图表。 首先，我使用 expand 函数开始。但问题是，程序应该等待所有的 Ad...

英文: Dags triggered by DagTriggenRunOperator are stuck in queue 问题 example_trigger_controller_dag.py ...

英文: Airflow BashOperator return exit code 0 even when task failed and return exit code 1 问题 我正在尝试使用A...

英文: How do I assign Cloud Composer DAGs to run on specific Node Pools? 问题 我正在使用Google Cloud上的Cloud C...

英文: How to call a REST end point using Airflow DAG 问题 我是新手使用Apache Airflow。我想使用DAG调用一个REST端点。 例如的RES...