File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed
Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -433,18 +433,18 @@ def dataset_create(
433433 package .load_dataset_resource (
434434 dataset_resource_dir / dataset / f"{ path_obj .stem } .csv"
435435 )
436- logging .info (f"loading old entities into { output_path } " )
436+ logger .info (f"loading old entities into { output_path } " )
437437 old_entity_path = Path (pipeline .path ) / "old-entity.csv"
438438 if old_entity_path .exists ():
439439 package .load_old_entities (old_entity_path )
440440
441- logging .info (f"loading issues into { output_path } " )
441+ logger .info (f"loading issues into { output_path } " )
442442 issue_paths = issue_dir / dataset
443443 if issue_paths .exists ():
444444 for issue_path in os .listdir (issue_paths ):
445445 package .load_issues (os .path .join (issue_paths , issue_path ))
446446 else :
447- logging .warning ("No directory for this dataset in the provided issue_directory" )
447+ logger .warning ("No directory for this dataset in the provided issue_directory" )
448448
449449 # Repeat for parquet
450450 # Set up cache directory to store parquet files. The sqlite files created from this will be saved in the dataset
Original file line number Diff line number Diff line change @@ -131,7 +131,7 @@ def load_facts(self, transformed_parquet_dir):
131131 """
132132 output_path = self .fact_path
133133 output_path .parent .mkdir (parents = True , exist_ok = True )
134- logging .info ("loading facts from temp table " )
134+ logger .info (f "loading facts from from { str ( transformed_parquet_dir ) } " )
135135
136136 fact_fields = self .specification .schema ["fact" ]["fields" ]
137137 fields_str = ", " .join ([field .replace ("-" , "_" ) for field in fact_fields ])
@@ -155,7 +155,7 @@ def load_facts(self, transformed_parquet_dir):
155155 )
156156
157157 def load_fact_resource (self , transformed_parquet_dir ):
158- logging .info (f"loading fact resources from { str (transformed_parquet_dir )} " )
158+ logger .info (f"loading fact resources from { str (transformed_parquet_dir )} " )
159159 output_path = self .fact_resource_path
160160 output_path .parent .mkdir (parents = True , exist_ok = True )
161161 fact_resource_fields = self .specification .schema ["fact-resource" ]["fields" ]
You can’t perform that action at this time.
0 commit comments