我正在运行气流管道，但代码看起来不错，但实际上我在DAG中检测到了airflow.exceptions.AirflowException: Cycle。错误任务:您可以帮助解决此问题吗
浏览 4提问于2017-08-17得票数 9
我们正在升级到气流2.0，我有以下任务： cms_ingest = SubDagOperator(
在我<em
浏览 1提问于2021-05-05得票数 1
回答已采纳
我负责这个DAG。它从dash_workers.py导入函数(不包括，但是--这会有帮助吗？)并将这些函数实现为PythonOperator定义的任务。这两个函数都在内部使用MySqlHook，并且我已经在独立的基础上测试了每个函数/任务，以确保它们独立地产生预期的行为(它们确实如此)。错误的关键似乎是行airflow.exceptions.AirflowException: Dependency <
浏览 2提问于2017-07-21得票数 1
回答已采纳
1回答
有没有一种在循环中运行气流DAG的方法？当尝试创建一个循环(将最后一个组件连接到最后一个组件的上游)时，我得到“在DAG中检测到循环。错误任务：...”通常，我有一个由3个BashOperator组件组成的短流，我希望它们连续运行(不需要从最后一个组件到第一个组件的任何输入-输出传递)。谢谢!
浏览 6提问于2017-12-24得票数 7
回答已采纳
我最近开始使用Apache气流，在使用了传统的创建DAG和任务的方法之后，我决定使用Taskflow API。然而，我遇到了一些问题，下面是我的问题。= ab_test_dag()
Question1)结果表明，除了最后一个任务之外，每个任务都必须返回某种值，即使它不会在管道中进一步使用。因为，否则气流会抛出错误，说airflow.exceptions.AirflowException: XComA
浏览 12提问于2022-07-20得票数 0
我试图在气流中执行以下任务：t1= BashOperator( bash_commandf'--arg2 {{ execution_date + timedelta(days=1).astimezone(pytz.timezone({time_zone})) }}'),我遇到
浏览 0提问于2019-03-28得票数 0
回答已采纳
我正在尝试通过Google Cloud Composer的KubernetesPodOperator在从私有Google Container Registry中的图像构建的环境中运行任务。Container Registry和Cloud Composer实例在同一个项目下。我的代码如下。the the pipeline 'my_dag',
浏览 0提问于2020-09-21得票数 0
Requirement：我试图避免使用Variable.get()，而使用Jinja模板化的{{var.json.variable}}snflk_json "snwflke_acct_request_memory":"4000Mi",
"snwflke_acct_limit_memory":"4000Mi错误:无效的</
浏览 9提问于2022-12-02得票数 0
1回答
(similar to proc1):proc2.py中的操作应该在完成proc1后启动。因此，我尝试创建一个新的DAG (run_all.py)，尝试这样做： run_this = BaseOperator()
run_all_dag = DAG(...
浏览 3提问于2016-10-13得票数 3
回答已采纳
我正在尝试根据气流变量创建动态任务： ? dependencies
start >> read_src1 >> upload_file_to_directory_bulk1 >> write_Snowflake1 >> end 我遇到了下面的错误： Broken DAG: [/home/dif/airflow/dags/target_dag.py] Traceback (most recent call
浏览 83提问于2021-06-21得票数 1
回答已采纳
我有一系列任务，用于启动容器并在其中运行python脚本。但是，我需要挂载包含python代码的卷...在遇到许多错误后，我发现不再支持添加卷，现在必须指定一个装载对象：https://github.com/apache/airflow/pull/15843 我的任务代码如下所示： from airflow.operators.docker_operatordocker_url="unix://va
浏览 15提问于2021-08-03得票数 0
回答已采纳
2回答
中有一个错误。例如，我将echo错误地拼写为eko。我在控制台中得到的唯一消息是：---operators/bash_operator.py", line 135, in executeairflow.excep
浏览 2提问于2019-07-04得票数 2
从气流文档和在互联网上读取不同的站点，非常清楚的是，任务名称和task_id在使用操作员创建任务时不需要匹配。= DAG( default_args=default_args, max_active_runssome_task_name >> another_task_name气流试验etl_sc
浏览 2提问于2019-11-27得票数 0
回答已采纳
我有一个按计划运行的DAG，其中的任务在路径中查找文件，对其进行处理，然后将该文件移动到归档文件夹中。当计划的DAG</
浏览 1提问于2019-01-18得票数 0
我已经在我的DAG中添加了一个任务，并且一直在尝试在任务还不存在的日期执行airflow backfill操作。我为我的命令提供了一个--task_regex、一个--start_date和一个--end_date参数。一切似乎工作正常，但在回填一些DAG运行后，Airflow崩溃并出现以下错误： [2019-06-06 12:13:25,378] {jobs.py:2521} INFO - Tas
浏览 15提问于2019-06-07得票数 0
我正在尝试基于数据库调用的响应动态创建任务。但是当我这样做时，run选项就不能进入气流，所以我不能运行。当我这样做的时候，我没有运行的选项，它看起来像是dag坏了。有什么帮助吗？尝试了很长时间。
浏览 0提问于2019-08-29得票数 0
在遵循中给出的步骤之后，我最近将气流从1.10.11升级到2.2.3。我第一次升级到1.10.15，就像建议的那样，效果不错。但是在升级到2.2.3之后，当任务进入排队状态时，我无法从UI执行DAG。当我检查任务荚日志时，我会看到以下错误：
[2022-02-22 06:46:23,886] {cli_action_loggers.py:105} WARNING - Failed to log action/utils&#x
浏览 10提问于2022-02-22得票数 2
回答已采纳
以前，我有在DAG步骤中获取这些参数的代码(我使用的是气流2中的Taskflow API ) --类似于这样：from airflow.decorators我知道错误在说什么，以及如何修复它(将代码移回@task中以获取上下文)。但我的问题是--为什么DAG导入会出现错误呢？在其他任务之外<e
浏览 5提问于2021-10-21得票数 3
回答已采纳
所以，我对ETL管道很陌生，我正在尝试创建一个dag。进程很好地启动，第一个任务(unzip_data)运行，但其他任务无法运行。你能帮我指出原因吗？以下是完整的代码：from datetime import timedeltafrom> <task name>时，对每个任务都会得到以下类似的错误
```Traceback (most re
浏览 13提问于2022-04-20得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
