Skip to content

Commit 75608d2

Browse files
committed
[DOP-32998] Remove tag key normalization
1 parent af72cb7 commit 75608d2

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

data_rentgen/consumer/extractors/generic/dataset.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ def _enrich_dataset_tags(self, dataset_dto: DatasetDTO, dataset: OpenLineageData
118118

119119
for raw_tag in dataset.facets.tags.tags:
120120
tag_value = TagValueDTO(
121-
tag=TagDTO(name=raw_tag.key.lower().replace(" ", "_")),
121+
tag=TagDTO(name=raw_tag.key),
122122
value=raw_tag.value,
123123
)
124124
dataset_dto.tag_values.add(tag_value)

data_rentgen/consumer/extractors/generic/job.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ def _enrich_job_tags(self, job_dto: JobDTO, job: OpenLineageJob) -> JobDTO:
6565

6666
for raw_tag in job.facets.tags.tags:
6767
tag_value = TagValueDTO(
68-
tag=TagDTO(name=raw_tag.key.lower().replace(" ", "_")),
68+
tag=TagDTO(name=raw_tag.key),
6969
value=raw_tag.value,
7070
)
7171
job_dto.tag_values.add(tag_value)

data_rentgen/consumer/extractors/generic/run.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ def _enrich_run_tags(self, run: RunDTO, event: OpenLineageRunEvent) -> RunDTO:
125125

126126
for raw_tag in event.run.facets.tags.tags:
127127
tag_value = TagValueDTO(
128-
tag=TagDTO(name=raw_tag.key.lower().replace(" ", "_")),
128+
tag=TagDTO(name=raw_tag.key),
129129
value=raw_tag.value,
130130
)
131131
run.job.tag_values.add(tag_value)

0 commit comments

Comments
 (0)