change BinaryOperation to ConditionOperation

sdk/python/kfp/compiler/compiler_utils.py

@@ -120,7 +120,7 @@ def _get_parent_groups_helper(
 
 
 def get_channels_from_condition(
-    operations: List[pipeline_channel.BinaryOperation],
+    operations: List[pipeline_channel.ConditionOperation],
     collected_channels: list,
 ) -> None:
     """Appends to collected_channels each pipeline channels used in each

sdk/python/kfp/compiler/pipeline_spec_builder.py

@@ -710,9 +710,9 @@ def _update_task_spec_for_loop_group(
 
 
 def _binary_operations_to_cel_conjunctive(
-        operations: List[pipeline_channel.BinaryOperation]) -> str:
-    """Converts a list of BinaryOperation to a CEL string with placeholders.
-    Each BinaryOperation will be joined the others via the conjunctive (&&).
+        operations: List[pipeline_channel.ConditionOperation]) -> str:
+    """Converts a list of ConditionOperation to a CEL string with placeholders.
+    Each ConditionOperation will be joined the others via the conjunctive (&&).
 
     Args:
         operations: The binary operations to convert to convert and join.
@@ -728,8 +728,8 @@ def _binary_operations_to_cel_conjunctive(
 
 
 def _single_binary_operation_to_cel_condition(
-        operation: pipeline_channel.BinaryOperation) -> str:
-    """Converts a BinaryOperation to a CEL string with placeholders.
+        operation: pipeline_channel.ConditionOperation) -> str:
+    """Converts a ConditionOperation to a CEL string with placeholders.
 
     Args:
         operation: The binary operation to convert to a string.

sdk/python/kfp/dsl/pipeline_channel.py

@@ -24,7 +24,7 @@
 
 
 @dataclasses.dataclass
-class BinaryOperation:
+class ConditionOperation:
     """Represents a condition expression to be used in condition control flow
     group.
 
@@ -152,22 +152,22 @@ def __hash__(self) -> int:
         return hash(self.pattern)
 
     def __eq__(self, other):
-        return BinaryOperation('==', self, other)
+        return ConditionOperation('==', self, other)
 
     def __ne__(self, other):
-        return BinaryOperation('!=', self, other)
+        return ConditionOperation('!=', self, other)
 
     def __lt__(self, other):
-        return BinaryOperation('<', self, other)
+        return ConditionOperation('<', self, other)
 
     def __le__(self, other):
-        return BinaryOperation('<=', self, other)
+        return ConditionOperation('<=', self, other)
 
     def __gt__(self, other):
-        return BinaryOperation('>', self, other)
+        return ConditionOperation('>', self, other)
 
     def __ge__(self, other):
-        return BinaryOperation('>=', self, other)
+        return ConditionOperation('>=', self, other)
 
 
 class PipelineParameterChannel(PipelineChannel):

sdk/python/kfp/dsl/tasks_group.py

@@ -151,15 +151,15 @@ class _ConditionBase(TasksGroup):
 
     def __init__(
         self,
-        conditions: List[pipeline_channel.BinaryOperation],
+        conditions: List[pipeline_channel.ConditionOperation],
         name: Optional[str] = None,
     ) -> None:
         super().__init__(
             group_type=TasksGroupType.CONDITION,
             name=name,
             is_root=False,
         )
-        self.conditions: List[pipeline_channel.BinaryOperation] = conditions
+        self.conditions: List[pipeline_channel.ConditionOperation] = conditions
 
 
 class If(_ConditionBase):
@@ -315,9 +315,9 @@ class InvalidControlFlowException(Exception):
 
 
 def _shallow_copy_list_of_binary_operations(
-    operations: List[pipeline_channel.BinaryOperation]
-) -> List[pipeline_channel.BinaryOperation]:
-    # shallow copy is sufficient to allow us to invert the negate flag of a BinaryOperation without affecting copies. deep copy not needed and would result in many copies of the full pipeline since PipelineChannels hold references to the pipeline.
+    operations: List[pipeline_channel.ConditionOperation]
+) -> List[pipeline_channel.ConditionOperation]:
+    # shallow copy is sufficient to allow us to invert the negate flag of a ConditionOperation without affecting copies. deep copy not needed and would result in many copies of the full pipeline since PipelineChannels hold references to the pipeline.
     return [copy.copy(operation) for operation in operations]