fix dataset name

astronomer · Sep 7, 2024 · 10d1eae · 10d1eae
1 parent 1f1fc61
commit 10d1eae
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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)