From 10d1eae913335bf7e35277aa9b2fdda01629238a Mon Sep 17 00:00:00 2001 From: t0momi219 Date: Sat, 7 Sep 2024 16:15:22 +0900 Subject: [PATCH] fix dataset name --- cosmos/operators/local.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cosmos/operators/local.py b/cosmos/operators/local.py index 49bf45293..582bcaadf 100644 --- a/cosmos/operators/local.py +++ b/cosmos/operators/local.py @@ -7,6 +7,7 @@ from abc import ABC, abstractmethod from functools import cached_property from pathlib import Path +import urllib.parse from typing import TYPE_CHECKING, Any, Callable, Literal, Sequence import jinja2 @@ -450,7 +451,7 @@ def get_datasets(self, source: Literal["inputs", "outputs"]) -> list[Dataset]: uris = [] for completed in self.openlineage_events_completes: for output in getattr(completed, source): - dataset_uri = output.namespace + "/" + output.name + dataset_uri = output.namespace + "/" + urllib.parse.quote(output.name) uris.append(dataset_uri) self.log.debug("URIs to be converted to Dataset: %s", uris)