diff options
| author | T-Aji <tolujbd2@gmail.com> | 2024-08-28 14:39:13 +0100 |
|---|---|---|
| committer | T-Aji <tolujbd2@gmail.com> | 2024-08-28 14:39:13 +0100 |
| commit | d064b2ec2c7393f8de50560a7edfe100851bfea3 (patch) | |
| tree | 5d5620d268bb6855f1e053225434c5e562dd353c | |
| parent | 03a5959df25f74d52ed5393c2a5af6b1b9eb34c9 (diff) | |
| download | de-project-bentley-d064b2ec2c7393f8de50560a7edfe100851bfea3.tar.gz de-project-bentley-d064b2ec2c7393f8de50560a7edfe100851bfea3.zip | |
debugging load_lambda
| -rw-r--r-- | src/load_lambda.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/load_lambda.py b/src/load_lambda.py index 926b4db..272cb8c 100644 --- a/src/load_lambda.py +++ b/src/load_lambda.py @@ -164,13 +164,13 @@ def upload_dfs_to_database(): "dim_date.parquet", # this needs to be mutable "dim_location.parquet", "dim_staff.parquet", - "dim_design.parquet", + "dim_design.parquet" ] mutable_df_dict = [ "fact_sales_order", "fact_purchase_order", "fact_payment", - "dim_currency", + "dim_currency" ] for file_name, df in dict_of_dfs.items(): @@ -182,6 +182,7 @@ def upload_dfs_to_database(): df.to_sql( table_name, con=db_engine, + schema="project_team_2", if_exists="append", index=False, ) |