refactor: rename evaluate_control_activity_iterations to evaluate_con…

…trol_activities
microsoft · Nov 24, 2023 · e5058e6 · e5058e6
1 parent d7d2bdb
commit e5058e6
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/src/azure_data_factory_testing_framework/models/activities/control_activity.py b/src/azure_data_factory_testing_framework/models/activities/control_activity.py
@@ -13,7 +13,7 @@ def __init__(self, **kwargs: Any) -> None:  # noqa: ANN401
         """
         super(Activity, self).__init__(**kwargs)
 
-    def evaluate_control_activity_iterations(
+    def evaluate_control_activities(
         self,
         state: PipelineRunState,
         evaluate_activities: Callable[[List[Activity], PipelineRunState], Iterator[Activity]],

diff --git a/src/azure_data_factory_testing_framework/models/activities/for_each_activity.py b/src/azure_data_factory_testing_framework/models/activities/for_each_activity.py
@@ -32,7 +32,7 @@ def evaluate(self, state: PipelineRunState) -> "ForEachActivity":
 
         return self
 
-    def evaluate_control_activity_iterations(
+    def evaluate_control_activities(
         self,
         state: PipelineRunState,
         evaluate_activities: Callable[[List[Activity], PipelineRunState], Iterator[Activity]],

diff --git a/src/azure_data_factory_testing_framework/models/activities/if_condition_activity.py b/src/azure_data_factory_testing_framework/models/activities/if_condition_activity.py
@@ -35,7 +35,7 @@ def evaluate(self, state: PipelineRunState) -> "IfConditionActivity":
 
         return self
 
-    def evaluate_control_activity_iterations(
+    def evaluate_control_activities(
         self,
         state: PipelineRunState,
         evaluate_activities: Callable[[List[Activity], PipelineRunState], Iterator[Activity]],

diff --git a/src/azure_data_factory_testing_framework/models/activities/switch_activity.py b/src/azure_data_factory_testing_framework/models/activities/switch_activity.py
@@ -35,7 +35,7 @@ def evaluate(self, state: PipelineRunState) -> "SwitchActivity":
 
         return self
 
-    def evaluate_control_activity_iterations(
+    def evaluate_control_activities(
         self,
         state: PipelineRunState,
         evaluate_activities: Callable[[List[Activity], PipelineRunState], Iterator[Activity]],

diff --git a/src/azure_data_factory_testing_framework/models/activities/until_activity.py b/src/azure_data_factory_testing_framework/models/activities/until_activity.py
@@ -32,7 +32,7 @@ def evaluate(self, state: PipelineRunState) -> "UntilActivity":
 
         return self
 
-    def evaluate_control_activity_iterations(
+    def evaluate_control_activities(
         self,
         state: PipelineRunState,
         evaluate_activities: Callable[[List[Activity], PipelineRunState], Iterator[Activity]],

diff --git a/src/azure_data_factory_testing_framework/test_framework.py b/src/azure_data_factory_testing_framework/test_framework.py
@@ -144,7 +144,7 @@ def evaluate_activities(self, activities: List[Activity], state: PipelineRunStat
 
                     if isinstance(activity, ControlActivity):
                         control_activity: ControlActivity = activity
-                        for child_activity in control_activity.evaluate_control_activity_iterations(
+                        for child_activity in control_activity.evaluate_control_activities(
                             state,
                             self.evaluate_activities,
                         ):