Ignore invalid filepaths to create the dbt dir cache key

astronomer · Jul 16, 2024 · e0d45f3 · e0d45f3
1 parent ad9024e
commit e0d45f3
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 5 deletions.
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -1,7 +1,7 @@
 Changelog
 =========
 
-1.5.1a2 (2024-07-17)
+1.5.1a3 (2024-07-17)
 --------------------
 
 Bug fixes

diff --git a/cosmos/__init__.py b/cosmos/__init__.py
@@ -5,7 +5,7 @@
 
 Contains dags, task groups, and operators.
 """
-__version__ = "1.5.1a2"
+__version__ = "1.5.1a3"
 
 from cosmos.airflow.dag import DbtDag
 from cosmos.airflow.task_group import DbtTaskGroup

diff --git a/cosmos/cache.py b/cosmos/cache.py
@@ -230,9 +230,12 @@ def _create_folder_version_hash(dir_path: Path) -> str:
         filepaths.extend(paths)
 
     for filepath in sorted(filepaths):
-        with open(str(filepath), "rb") as fp:
-            buf = fp.read()
-            hasher.update(buf)
+        try:
+            with open(str(filepath), "rb") as fp:
+                buf = fp.read()
+                hasher.update(buf)
+        except FileNotFoundError:
+            logger.debug(f"Skipping invalid path {filepath}")
 
     return hasher.hexdigest()