diff options
| author | Ang Bel <anzelikabelotelova@Anzelikas-MacBook-Air.local> | 2024-08-28 22:46:00 +0100 |
|---|---|---|
| committer | Ang Bel <anzelikabelotelova@Anzelikas-MacBook-Air.local> | 2024-08-28 22:46:00 +0100 |
| commit | d396cd95d660fb76188ef887fc268d20aeeb5352 (patch) | |
| tree | 52fced39ff487d4053a3d43c24eb8bcf403c1719 /src/transform_lambda/transform_lambda.py | |
| parent | 6235a2bb04b60d57a41196b07bbf0296920c6980 (diff) | |
| download | de-project-bentley-d396cd95d660fb76188ef887fc268d20aeeb5352.tar.gz de-project-bentley-d396cd95d660fb76188ef887fc268d20aeeb5352.zip | |
fix: adds missing dataframes and resolves tables upload to end data warehouse in case the table is empty
Diffstat (limited to 'src/transform_lambda/transform_lambda.py')
| -rw-r--r-- | src/transform_lambda/transform_lambda.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/transform_lambda/transform_lambda.py b/src/transform_lambda/transform_lambda.py index 0b5748b..5ea8cf0 100644 --- a/src/transform_lambda/transform_lambda.py +++ b/src/transform_lambda/transform_lambda.py @@ -65,13 +65,15 @@ def lambda_handler(event, context): "dim_location": create_dim_location(dict_of_df), "dim_staff": create_dim_staff(dict_of_df), "dim_design": create_dim_design(dict_of_df), + "dim_transaction": create_dim_transaction(dict_of_df), + "dim_payment_type": create_dim_payment_type(dict_of_df) } mutable_df_dict = { "fact_sales_order": create_fact_sales_order(dict_of_df), "fact_purchase_order": create_fact_purchase_orders(dict_of_df), "fact_payment": create_fact_payment(dict_of_df), - "dim_currency": create_dim_currency(dict_of_df), + "dim_currency": create_dim_currency(dict_of_df) } print(immutable_df_dict.values()) print(mutable_df_dict.values()) |