Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit 6b14972

Browse files
committed
Add logs to indicate current artifact being parsed in debug mode
1 parent 7a5769d commit 6b14972

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

data_diff/dbt_parser.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@ def get_datadiff_variables(self) -> dict:
6868

6969
def get_models(self):
7070
with open(self.project_dir / RUN_RESULTS_PATH) as run_results:
71+
logger.info(f"Parsing file {RUN_RESULTS_PATH}")
7172
run_results_dict = json.load(run_results)
7273
run_results_obj = self.parse_run_results(run_results=run_results_dict)
7374

@@ -91,18 +92,21 @@ def get_models(self):
9192

9293
def get_manifest_obj(self):
9394
with open(self.project_dir / MANIFEST_PATH) as manifest:
95+
logger.info(f"Parsing file {MANIFEST_PATH}")
9496
manifest_dict = json.load(manifest)
9597
manifest_obj = self.parse_manifest(manifest=manifest_dict)
9698
return manifest_obj
9799

98100
def get_project_dict(self):
99101
with open(self.project_dir / PROJECT_FILE) as project:
102+
logger.info(f"Parsing file {PROJECT_FILE}")
100103
project_dict = self.yaml.safe_load(project)
101104
return project_dict
102105

103106
def get_connection_creds(self) -> Tuple[Dict[str, str], str]:
104107
profiles_path = self.profiles_dir / PROFILES_FILE
105108
with open(profiles_path) as profiles:
109+
logger.info(f"Parsing file {profiles_path}")
106110
profiles = self.yaml.safe_load(profiles)
107111

108112
dbt_profile_var = self.project_dict.get("profile")

0 commit comments

Comments
 (0)