Skip to content

Commit 11c2abc

Browse files
committed
[argo] fix bug in jobset owner reference
1 parent 5c960ea commit 11c2abc

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

metaflow/plugins/argo/argo_workflows.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -2017,6 +2017,7 @@ def _container_templates(self):
20172017
kubernetes_labels = {
20182018
"task_id_entropy": "{{inputs.parameters.task-id-entropy}}",
20192019
"num_parallel": "{{inputs.parameters.num-parallel}}",
2020+
20202021
}
20212022
jobset.labels(
20222023
{
@@ -3631,7 +3632,7 @@ def to_json(self):
36313632
def resource(self, action, manifest, success_criteria, failure_criteria):
36323633
self.payload["resource"] = {}
36333634
self.payload["resource"]["action"] = action
3634-
self.payload["setOwnerReference"] = True
3635+
self.payload["resource"]["setOwnerReference"] = True
36353636
self.payload["resource"]["successCondition"] = success_criteria
36363637
self.payload["resource"]["failureCondition"] = failure_criteria
36373638
self.payload["resource"]["manifest"] = manifest

0 commit comments

Comments
 (0)