fix: deserializing until and foreach activities in pipeline

microsoft · Dec 1, 2023 · 36b5592 · 36b5592
1 parent c6ee8a2
commit 36b5592
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/azure_data_factory_testing_framework/deserializers/shared/_activity_deserializer.py b/src/azure_data_factory_testing_framework/deserializers/shared/_activity_deserializer.py
@@ -18,7 +18,7 @@ def _get_activity_from_activity_data(activity_data: dict) -> Activity:
     if activity_data["type"] == "AppendVariable":
         return AppendVariableActivity(**activity_data)
     elif activity_data["type"] == "Until":
-        activities = _get_activity_from_activities_data(activity_data["activities"])
+        activities = _get_activity_from_activities_data(activity_data["typeProperties"]["activities"])
         return UntilActivity(activities=activities, **activity_data)
     elif activity_data["type"] == "ExecutePipeline":
         return ExecutePipelineActivity(**activity_data)
@@ -29,7 +29,7 @@ def _get_activity_from_activity_data(activity_data: dict) -> Activity:
             if_true_activities=if_true_activities, if_false_activities=if_false_activities, **activity_data
         )
     elif activity_data["type"] == "ForEach":
-        child_activities = _get_activity_from_activities_data(activity_data["activities"])
+        child_activities = _get_activity_from_activities_data(activity_data["typeProperties"]["activities"])
         return ForEachActivity(activities=child_activities, **activity_data)
     elif activity_data["type"] == "Switch":
         default_activities = _get_activity_from_activities_data(activity_data["typeProperties"]["defaultActivities"])