From ad9024e4804d1305326ff43b337ad19e70ed7aca Mon Sep 17 00:00:00 2001 From: Tatiana Al-Chueyr Date: Wed, 17 Jul 2024 00:28:32 +0100 Subject: [PATCH] Improve logs further for 1.5.1a2 release --- CHANGELOG.rst | 2 +- cosmos/__init__.py | 3 +-- cosmos/cache.py | 2 +- cosmos/dbt/graph.py | 3 ++- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 1f18c0f52..146c7b2f2 100644 --- 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 index 85d56ff7f..611b99b5b 100644 --- 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 index e8c4db894..1e83e739b 100644 --- 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 index 22a30e1ab..23413b1fe 100644 --- 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,