我已将 Airflow 2.5.1 部署在带有官方 helm 图表的 Kubernetes 集群上。执行者是 KubernetesExecutor。 我想在 Stackdriver 上远程写入和读取气...

有没有办法根据输入参数确定 Dagrun 的优先级？ 情况： 我有一个 Airflow Dag，其管道包含连续的长时间运行的任务。根据输入参数值，我需要对 Dagrun 的一些实例进行优先级排序。 ...

我想每天安排一个 dag，但在一天中的不同时间，例如： 星期一 16H 星期二 9H 星期三 10H ... 星期一 15H 星期二 12H 等。。。 我怎样才能做到这一点？...

我有一些 python 脚本，我希望每天从 Windows PC 上运行。 我目前的工作流程是： 台式电脑每天都会保持状态，除了周末每周重启一次 重新启动后，我打开 VS Code 并运行一个小的...

我有一个运行 4 个任务的 dag，这些任务都是 bash 运算符。最近我搬到了 airflow 版本 1.10.2。我经常看到以下错误： ERROR - Scheduler heartbeat g...

我正在使用带有 Airflow 的 Google Cloud Composer 在 Snowflake 上运行 SQL 查询。我需要根据条件设置日期参数，然后在我的 SQL 文件中使用该参数。具体来说...

我正在尝试像这样将连接字符串从机密管理器传递到 mssqlhook mssql+pyodbc://username:password@host\instance:port/schema 当我在...

我面临的问题是，到目前为止，这个问题是可以控制的。在我的 conda 环境中安装本地包后，我需要添加一个标志来运行项目中的任何脚本，例如简单的数据提取脚本： 最初，它很好;我只是添加了标志，开发仍在...