Skip to content

Commit 76f0b5e

Browse files
committed
Just a debug comment to check the schema retrieved
1 parent 70d338a commit 76f0b5e

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,4 +6,5 @@ venv
66
data_files/
77
*.log
88
*.log.1
9+
*.log.*
910
*.ipynb

schema_utils.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -283,8 +283,13 @@ def process_dataframe(table_name_param: str, df: pd.DataFrame):
283283

284284
processed_col_name = schemas.find_column_renaming(table_name, col_name)
285285
schema_of_this_column = schemas.get_table_column_schema(table_name, col_name)
286-
286+
logger.debug(
287+
f"%%%% In process_df: schema_of_this_column is {schema_of_this_column} %%%%%"
288+
)
287289
if not processed_col_name and not schema_of_this_column:
290+
logger.debug(
291+
f"%%%% In process_df, schema of col doesnt exist: schema_of_this_column is {schema_of_this_column} and processed_col_name is {processed_col_name} %%%%%"
292+
)
288293
# new column, process it and append schema
289294
schema_of_this_column = init_column_schema(
290295
current_dtype, current_first_item

0 commit comments

Comments
 (0)