Improve logs further for 1.5.1a2 release

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

Hide file tree

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

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

diff --git a/cosmos/cache.py b/cosmos/cache.py
@@ -247,7 +247,7 @@ def _calculate_dbt_ls_cache_current_version(cache_identifier: str, project_dir:
     :param cmd_args: List containing the arguments passed to the dbt ls command that would affect its output
     """
     logger.info(
-        f"_calculate_dbt_ls_cache_current_version for {cache_identifier} received the project_dir: {project_dir}"
+        f"_calculate_dbt_ls_cache_current_version for {cache_identifier} received the project_dir: {project_dir} and cmd_args: {cmd_args}"
     )
     start_time = time.perf_counter()
 

diff --git a/cosmos/dbt/graph.py b/cosmos/dbt/graph.py
@@ -187,7 +187,7 @@ def env_vars(self) -> dict[str, str]:
         """
         return self.render_config.env_vars or self.project.env_vars or {}
 
-    @cached_property
+    @property
     def project_path(self) -> Path:
         """
         Return the user-defined path to their dbt project. Tries to retrieve the configuration from render_config and
@@ -262,6 +262,7 @@ def save_dbt_ls_cache(self, dbt_ls_output: str) -> None:
         compressed_data = zlib.compress(dbt_ls_output.encode("utf-8"))
         encoded_data = base64.b64encode(compressed_data)
         dbt_ls_compressed = encoded_data.decode("utf-8")
+        logger.info(f"save_dbt_ls_cache for {self.dbt_ls_cache_key}: self.project_path: {self.project_path}")
         cache_dict = {
             "version": cache._calculate_dbt_ls_cache_current_version(
                 cache_identifier=self.dbt_ls_cache_key,