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 index a132f2dfc8..edb57599db 100644 --- 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 index b201c2c3a4..2026fe0b0f 100644 --- 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 } )