From 4b84c14cb555d3ce9b1f1d7066db149ca5b1cdd2 Mon Sep 17 00:00:00 2001 From: Maiara Reinaldo Date: Tue, 20 Feb 2024 18:06:06 +0000 Subject: [PATCH] Switch on nested metamapping --- metadata-ingestion/src/datahub/ingestion/source/kafka.py | 1 - metadata-ingestion/tests/unit/test_mapping.py | 1 - 2 files changed, 2 deletions(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/kafka.py b/metadata-ingestion/src/datahub/ingestion/source/kafka.py index 0523ec24ebf04..53977c5e96c7e 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/kafka.py +++ b/metadata-ingestion/src/datahub/ingestion/source/kafka.py @@ -208,7 +208,6 @@ def __init__(self, config: KafkaSourceConfig, ctx: PipelineContext): self.source_config.tag_prefix, OwnershipSourceTypeClass.SERVICE, self.source_config.strip_user_ids_from_email, - match_nested_props=True, ) def init_kafka_admin_client(self) -> None: diff --git a/metadata-ingestion/tests/unit/test_mapping.py b/metadata-ingestion/tests/unit/test_mapping.py index 078c79ab5a9b7..d8a430c7167d6 100644 --- a/metadata-ingestion/tests/unit/test_mapping.py +++ b/metadata-ingestion/tests/unit/test_mapping.py @@ -329,7 +329,6 @@ def test_operation_processor_matching_dot_props(): }, }, owner_source_type="SOURCE_CONTROL", - match_nested_props=True, ) aspect_map = processor.process(raw_props) assert "add_tag" in aspect_map