Renaming identity_or_reference_fields_paths to incoming_field_paths

ethyca · Dec 9, 2024 · 001b8ec · 001b8ec
1 parent 6a10d87
commit 001b8ec
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/fides/api/service/connectors/query_configs/mongodb_query_config.py b/src/fides/api/service/connectors/query_configs/mongodb_query_config.py
@@ -72,7 +72,7 @@ def generate_update_stmt(
         where_clauses: Dict[str, Any] = filter_nonempty_values(
             {
                 field_path.string_path: field.cast(row[field_path.string_path])
-                for field_path, field in self.identity_or_reference_field_paths.items()
+                for field_path, field in self.incoming_field_paths.items()
             }
         )
 

diff --git a/src/fides/api/service/connectors/query_configs/query_config.py b/src/fides/api/service/connectors/query_configs/query_config.py
@@ -101,8 +101,8 @@ def primary_key_field_paths(self) -> Dict[FieldPath, Field]:
         }
 
     @property
-    def identity_or_reference_field_paths(self) -> Dict[FieldPath, Field]:
-        """Mapping of FieldPaths to Fields that have identity or dataset references"""
+    def incoming_field_paths(self) -> Dict[FieldPath, Field]:
+        """Mapping of FieldPaths to Fields that have incoming identity or dataset references"""
         return {
             field_path: field
             for field_path, field in self.field_map().items()
@@ -450,7 +450,7 @@ def generate_update_stmt(
         non_empty_reference_fields: Dict[str, Field] = filter_nonempty_values(
             {
                 fpath.string_path: fld.cast(row[fpath.string_path])
-                for fpath, fld in self.identity_or_reference_field_paths.items()
+                for fpath, fld in self.incoming_field_paths.items()
                 if fpath.string_path in row
             }
         )