1回答
我想暂停空闲和冗余的DAG，我如何知道哪些DAG未暂停，哪些DAG已暂停？
因此，我有一个要使用执行airflow pause <dag_id>的have命令取消暂停的DAG的列表。我想通过检查每个DAG的pause状态来了解命令是否成功。我已经检查了ai
浏览 0提问于2018-12-27得票数 4
是否有任何方法可以保留服务器的默认设置。..。但是对于一个特定的dag，默认情况下是否将其定义为未暂停？dag = DAG( default_args=default_args, schedule_interval
浏览 3提问于2017-07-27得票数 5
8回答
我有一个进程，我们将部署到多个不同的气流实例，在我们的airflow.cfg中，我们有dags_are_paused_at_creation = True，但是对于这个特定的进程，我们希望通过单击UI来打开它有办法以编程的方式完成吗？
浏览 8提问于2017-06-05得票数 16
回答已采纳
在airflow.cfg中设置catchup_by_default=False似乎不起作用。此外，将catchup=False添加到DAG也不起作用。这是dag的设置。我只是在用。default_args = {
"owner": "a
浏览 1提问于2018-09-05得票数 4
我想知道是否有一种方法可以在并行运行DAG时停止/启动单个DAG。dag_id上的暂停/取消暂停似乎是暂停/取消在一个守护进程下运行的所有dag。相反，我们希望暂停单个dagruns (或其中的任务)。让我知道这是否可以在气流中实现。
如果不可能，这里还有我正在考
浏览 1提问于2020-08-27得票数 1
回答已采纳
我对Airflow完全陌生，我真的很难让一个非常简单的测试DAG运行： from airflow import DAGfrom airflow.operators.bash import BashOperator
}
dag = <em
浏览 133提问于2021-02-01得票数 1
回答已采纳
我在Airflow UI中遇到无法暂停或取消暂停DAG的问题。我在浏览器网络控制台中看到了这个400错误。这似乎就发生在最近的气流构建中。我一直在使用1.10.10版本。is_paused=true&dag_id=test_dag 400
浏览 1提问于2020-07-28得票数 0
1回答
我使用的气流2.2.2，并有一个dag，这是计划运行每10分钟，并暂停。我正在尝试使用气流客户端手动调用它。Dag没有被取消暂停，dagrun也在排队，声明。在创建dag运行时，是否可以在不调用其他API调用的情况下使用气流客户端来取消dag。api_instance = dag_run_api.DAGRunApi(api_client)
浏览 6提问于2022-05-16得票数 1
我在代码中定义了以下DAG： from datetime import timedelta, datetimefrom airflow import DAGdata-push-for-red
data-push-for-yellow 然后，我通过在终端<em
浏览 49提问于2020-08-02得票数 1
回答已采纳
1回答
我需要用AWS、Lambda或其他方法禁用气流DAG。为了做到这一点，我可以使用python代码吗？提前谢谢你。
浏览 3提问于2022-03-08得票数 0
回答已采纳
2回答
我需要一些建议，如何重新启动所有的气流服务部署，而不杀死在任务中的工人。
更新“当前”simlink以指向我的新版本。我想在脚本中添加某种类型的监视，以暂停所有DAGs，等待工作人员空闲，然后重新启动服务，但气流CLI无法了解启用
浏览 3提问于2016-11-22得票数 6
回答已采纳
5回答
我正在尝试使用airflow来定义我想要从命令行手动触发的特定工作流。 "DAG_NAME", schedule_interval=None,default_args=args)airflow tr
浏览 2提问于2016-05-05得票数 24
我似乎不了解如何将模块导入到apache airflow DAG定义文件中。例如，我想这样做是为了能够创建一个库，使具有类似设置的声明任务不那么繁琐。这是我能想到的重复这个问题的最简单的例子:我修改了airflow教程(https://airflow.apache.org/tutorial.html#recap)，只需导入一个模块并从该模块运行一个定义defintion
浏览 197提问于2017-12-28得票数 29
回答已采纳
在我对airflow的第一次尝试中，我尝试运行安装附带的一个示例DAGS。这是v.1.8.0。以下是我的步骤：[2017-04-19 15:32:38,391] {__init__.py:57} INFO-19 15:32:38,676] {models.py:167} INFO - Filling up the DagBag from /Users&#
浏览 10提问于2017-04-20得票数 31
通过GCP命令将文件上传到DAG文件夹后，我想检查是否创建了DAG。我可以知道检查是否创建了暂停的DAG的命令吗？在这个问题中，我提到了"Pause DAG“，因为我使用的是"core-dags_are_paused_at_creation=true”配置。
存在load_dags，但它仅返回未暂停的DAG。
浏览 3提问于2020-01-14得票数 0
我正在使用Composer来调度多个DAG。这些DAG是使用动态构建的，它们使用自定义插件。
将插件上载到Composer集群的</em
浏览 3提问于2020-08-24得票数 0
在气流中，我应该如何处理错误“此DAG在webserver DagBag对象中不可用，它显示在此列表中，因为调度程序将其标记为元数据数据库中的活动”？我将一个新的DAG复制到一个气流服务器上，并尝试：
停止webserver和调度器，重置数据库运行
浏览 7提问于2017-04-28得票数 19
我正在创建一个python脚本来从模板生成DAG (生成一个带有DAG规范的新python文件)。除了我需要以不可暂停的方式生成DAG之外，这一切都很好。我搜索并尝试在脚本中运行shell命令，如下所示：
bash_command2 = 'airflow trigger_dag '(ba
浏览 1提问于2018-11-16得票数 2
回答已采纳
我无法从气流UI中看到附加到任务的日志：
airflow.cfg文件中与日志相关的设置如下：
child_process_log_directory= /home/my_pro
浏览 3提问于2017-08-03得票数 13
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
