Skip to content

Commit

Permalink
Switch on nested metamapping
Browse files Browse the repository at this point in the history
  • Loading branch information
maiarareinaldo committed Feb 20, 2024
1 parent 41cb4da commit 4b84c14
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 2 deletions.
1 change: 0 additions & 1 deletion metadata-ingestion/src/datahub/ingestion/source/kafka.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down
1 change: 0 additions & 1 deletion metadata-ingestion/tests/unit/test_mapping.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 4b84c14

Please sign in to comment.