Skip to content

Commit c77518d

Browse files
authored
Rename fix (#31)
1 parent 02a153b commit c77518d

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

scripts/cloud/etl/preprocessing.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -350,7 +350,7 @@ def prepare_features(transactions_df, aggregations_df, cols_dict):
350350

351351
aggregations_btc_df = glueContext.create_data_frame.from_catalog(
352352
database="bdp",
353-
table_name="aggregated_transactions",
353+
table_name="wallets_aggregations",
354354
additional_options = {
355355
"useCatalogSchema": True,
356356
"useSparkDataSource": True
@@ -359,7 +359,7 @@ def prepare_features(transactions_df, aggregations_df, cols_dict):
359359

360360
aggregations_eth_df = glueContext.create_data_frame.from_catalog(
361361
database="bdp",
362-
table_name="aggregated_transactions",
362+
table_name="wallets_aggregations",
363363
additional_options = {
364364
"useCatalogSchema": True,
365365
"useSparkDataSource": True

0 commit comments

Comments
 (0)