fix(sdk): Fix opsgroups dependency resolution

kubeflow · Aug 13, 2020 · 39eff4c · 39eff4c
1 parent 9c6738f
commit 39eff4c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sdk/python/kfp/compiler/compiler.py b/sdk/python/kfp/compiler/compiler.py
@@ -367,8 +367,8 @@ def _get_dependency_opsgroup(group, dependencies):
       for op_name in upstream_op_names:
         if op_name in pipeline.ops:
           upstream_op = pipeline.ops[op_name]
-        elif op_name in opsgroups_groups:
-          upstream_op = opsgroups_groups[op_name]
+        elif op_name in opsgroups:
+          upstream_op = opsgroups[op_name]
         else:
           raise ValueError('compiler cannot find the ' + op_name)
         upstream_groups, downstream_groups = \