From fc04e1f1fff2f963610d1937adb14efc45fd5b55 Mon Sep 17 00:00:00 2001
From: "macroscopeapp[bot]"
 <170038800+macroscopeapp[bot]@users.noreply.github.com>
Date: Wed, 25 Feb 2026 23:17:18 +0000
Subject: [PATCH] Fix cache key collision between dbt_ls and yaml_selectors
 Airflow Variables

---
 cosmos/dbt/graph.py | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/cosmos/dbt/graph.py b/cosmos/dbt/graph.py
index 1696c3991b..a2e5fc2b29 100644
--- a/cosmos/dbt/graph.py
+++ b/cosmos/dbt/graph.py
@@ -522,7 +522,7 @@ def save_dbt_ls_cache(self, dbt_ls_output: str) -> None:
             with remote_cache_key_path.open("w") as fp:
                 json.dump(cache_dict, fp)
         else:
-            Variable.set(self.cache_key, cache_dict, serialize_json=True)
+            Variable.set(f"{self.cache_key}_dbt_ls", cache_dict, serialize_json=True)
 
     def _get_dbt_ls_remote_cache(self, remote_cache_dir: Path | ObjectStoragePath) -> dict[str, str]:
         """Loads the remote cache for dbt ls."""
@@ -559,7 +559,7 @@ def get_dbt_ls_cache(self) -> dict[str, str]:
             cache_dict = (
                 self._get_dbt_ls_remote_cache(remote_cache_dir)
                 if remote_cache_dir
-                else Variable.get(self.cache_key, deserialize_json=True)
+                else Variable.get(f"{self.cache_key}_dbt_ls", deserialize_json=True)
             )
         except tuple(airflow_variable_exceptions):
             return cache_dict
@@ -980,7 +980,7 @@ def get_yaml_selectors_cache(self) -> dict[str, Any]:
             cache_dict = (
                 self._get_yaml_selectors_remote_cache(remote_cache_dir)
                 if remote_cache_dir
-                else Variable.get(self.cache_key, deserialize_json=True)
+                else Variable.get(f"{self.cache_key}_yaml_selectors", deserialize_json=True)
             )
         except tuple(airflow_variable_exceptions):
             return cache_dict
@@ -1039,7 +1039,7 @@ def save_yaml_selectors_cache(self, yaml_selectors: YamlSelectors) -> None:
             with remote_cache_key_path.open("w") as fp:
                 json.dump(cache_dict, fp)
         else:
-            Variable.set(self.cache_key, cache_dict, serialize_json=True)
+            Variable.set(f"{self.cache_key}_yaml_selectors", cache_dict, serialize_json=True)
 
     def parse_yaml_selectors(self, selector_definitions: dict[str, Any]) -> YamlSelectors:
         """