有向非循环图出现在许多数据结构中，例如分布式版本控制系统中的变更集图。
如果我有一个带有循环且只有正权重的有向图，并且不使用优先级队列，而是使用队列并继续添加所有子项，包括那些因为我选择而被访问的子项...
所以我有一个 Scrapy 项目，我可以将其容器化在 Docker 中，以及一个 Jupyter 笔记本（用于正常的数据预处理）。我想使用 Airflow 将它们自动化，但遇到了几个
Airflow DAG 调度问题：为每月和每周运行传递正确的执行日期
我面临 Airflow 的问题，即我的 DAG 未将正确的执行日期传递给 DAG 中的查询。我有两个 DAG，其中一个计划在每月第一天运行，并且
我有一个正在运行的谷歌云功能，我正在尝试从 Airflow DAG 调用它。 到目前为止我尝试过的是使用 SimpleHttpOperator： MY_TASK_NAME = SimpleHttpOperator( t...
我真的需要知道如何使用 Airflow 让多个 DAG 相互调用（例如 DAG_1 >> DAG_2），类似于它如何使用上游/下游运算符在 DAG 中运行任务。 我需要...
export_query: sql_query1 ; 导出查询过滤器：“” 处理模块： 'export_bqtobqtmp_task' 'export_bqtmptogcs_task' 'pre_shell_execution' 'post_shell_execution' 处理_依赖...
我创建了一个 dag 工厂。 我将 dag 切换到取消暂停状态，它们立即开始工作，尽管设置了计划间隔值。尝试通过指定 is_active=False 来覆盖 DagModel。
气流 DAG 出现错误，>> 不支持操作数类型：“列表”和“列表”。任务的顺序和并行执行
我是 Apache Airflow 和 DAG 的新手。 DAG 中共有 6 个任务（task1、task2、task3、task4、task5、task6）。但在运行 DAG 时，我们收到以下错误。 不支持 DAG
有没有办法使用R包ggraph（或类似的）绘制到网络节点的定向入口/出口点？
用例：我正在尝试使用优秀的 ggraph 包在 R 中绘制考古“哈里斯矩阵”。哈里斯矩阵是按时间顺序建模的关系有向图
在 Python 中分割 dag 依赖项 我尝试实现一个用于拆分 dag 依赖项的脚本，我的目标是拆分节点依赖项，以便对于具有多个依赖项的每个节点，我
Python 中的广度优先搜索（BFS）用于分割 dag 节点
Python 中的广度优先搜索 (BFS)，用于分割 dag 依赖项
我从 py 文件创建了一个 DAG。当我触发 DAG 时，它在第一个任务上挂起。我的日志是这样写的： [2022-04-16 20:51:05,371] {subprocess.py:74} 信息 - 运行命令：['bash', '-c', '...
是否可以将 PySpark ETL 管道的每个步骤分配给 Airflow DAG 的单独任务？
据我所知，我需要使用 SparkSubmitOperator 来提交我的 PySpark 脚本。但是，如果我想将 Spark 作业的提取、转换和加载部分分配给 Ai 中的不同任务该怎么办...
我想谈谈有向无环图中从一个节点到另一个节点有不止一条路径的地方。这不是一个“循环”，我该怎么称呼它呢？我使用“钻石”这个词，但是
有些任务从文件中读取数据，进行一些处理并写入文件。这些任务将根据依赖性进行调度。此外，任务可以并行运行，因此算法需要是
如何在不同的计划中运行具有不同参数的 Airflow DAG？
我有一个运行 python 文件的 DAG（例如 -- python /path/to/file.py -a -b -c -d），并且有多个参数要在运行此文件的命令中传递文件。现在，我想运行这个...
我在networkx中有一个有向图。 节点有一个“高度”标签。以下是高度为 0、1、2、3、4、5 和 6 的示例： 我想运行弹簧布局（二维），但是
docker 和气流（特别是 dockeroperator）的问题
我求助于你来帮助我解决很多天的问题。我在 docker 中的 ariflow 特定配置方面遇到问题。上下文是我正在配置几个容器以便......
我正在研究一个图问题，涉及具有 N 个节点和 M 个双向边的图。我使用 Dijkstra 算法从该图构建最短路径有向无环图 (DAG)，st...
尝试从 Google Cloud DAG 运行 python 脚本时出错
我已经在 Google Cloud 中的存储桶中创建了一个 DAG，并且想要运行我保存在存储桶的脚本文件夹中的 python 脚本。但是，我要么遇到 DAG 导入错误，要么遇到以下问题...