问题标签 [argo-workflows]

在使用 Argo Workflows 时，我们有一个场景来调用现有的微服务。我们可以通过脚本进行 HTTP 调用，但是这种方法每次都会创建一个新的 Pod，耗时较长。想知道这样做是否是一种好习惯以及最好的方法是什么？

根据Argo DAG 模板文档。

tasks.<TASKNAME>.outputs.parameters：当上一个任务使用 'withItems' 或 'withParams' 时，这包含每个调用的输出参数映射的 JSON 数组

尝试使用以下简单工作流程时：

我收到以下错误： Failed to submit workflow: templates.start.tasks.show-result failed to resolve {{tasks.with-items.outputs.parameters}}

Argo 版本（在 minikube 集群中运行）

Argo 2.8.1 中出现同样的错误，尽管在 show-result 任务中使用.result而不是.parameters正常工作（结果是[A,B,C]），但在 2.10 中不再工作

结果：

我还尝试将 show-result 任务更改为：

执行没有错误：

但是参数不会被值替换：

我不明白循环的输出会发生什么！我错过了什么？有没有办法找出正在发生的事情？

我在下面为 Argo 编写了一个工作流程，其中包含一个（基于容器的）模板和一个 DAG。DAG 应该将可变数量的值传递给模板的输入参数。

这可能吗？

我试图弄清楚如何使用Argo设置工作队列。Argo 工作流程的计算成本很高。我们需要计划许多同时的请求。工作流项通过 HTTP 请求添加到工作队列。

流程可以这样演示：

我从未构建过超出其资源的 K8s 集群。我在哪里限制工作流的执行？或者 Argo 事件和工作流是否根据集群中的资源限制这些？

上面的例子可能可以简化为下面的例子，但问题是如果处理队列已满，会发生什么？

我有一个菱形风格的工作流程，其中一个步骤A启动了可变数量的分析作业B以X使用withParam:. 作业的数量基于动态信息并且在第一步运行之前是未知的。这一切都很好，除了我还想要一个聚合器作业Y来运行所有这些分析作业的输出：

每个分析作业B-X编写工件，并Y需要所有这些作为输入。我不知道如何为Y. 这可能吗？我尝试传入 artifactkey的 JSON 数组，但 pod 卡在 pod 初始化上。我找不到任何关于如何做到这一点的例子。

A创建了几个由B-消耗的工件X（每个作业一个作为 的一部分withParam:）所以我知道我的工件存储库设置正确。

每个作业B-X需要大量 CPU，因此将在不同的节点上运行，所以我认为共享卷不会起作用（尽管我对跨不同节点共享卷知之甚少）。

Argo UI 显示 DAG 工作流的“重试”按钮，但如果某个步骤失败并且我使用它重试，它总是无法重试。Argo 甚至支持手动重试吗？

我有一个与 Argo Workflow & JINJA 模板相关的查询：

我知道 Argo 工作流支持诸如 {{ ... }} 之类的表达式的 JINJA 模板，但是 Argo 工作流是否也支持 JINJA 模板控制结构，例如：{% ... %} ..........

我在一个用例中苦苦挣扎，我需要在“单一”工作流模板中添加以下语句

我正在尝试在 EKS 上设置 AWS ALB 入口。但是 Argo UI 无法正常工作。但是端口转发工作正常。

访问端点时收到 404。

我使用 helm chart 来部署图表。

我尝试从入口文件中更改不同的值，但我没有成功。

为了20201008在 Argo 中获得日期，在模板中格式化日期的最佳方法是什么？

这似乎可行，但相当冗长，并且为类似的东西创建字符串对于其他"%Y-%m-%dT%H:%M:%SZ"人来说将变得非常难以阅读。

我认为这些是相关文档：https ://github.com/argoproj/argo/blob/master/docs/variables.md 。我试过"{{workflow.creationTimestamp.Ymd}}"但没有运气。

我有一个带有互斥锁的 argo 工作流程，例如

但是，我在尝试运行时删除了一个工作流。现在 argo 陷入了僵局，无法使用相同的互斥锁创建作业。

argo 在哪里存储互斥量信息？以及如何手动删除互斥锁信息以摆脱死锁？