diff options
| -rw-r--r-- | src/dataframes.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/dataframes.py b/src/dataframes.py index 36361d2..4b32b36 100644 --- a/src/dataframes.py +++ b/src/dataframes.py @@ -161,7 +161,7 @@ def create_dim_location(dict_of_df): def create_dim_counterparty(dict_of_df): - df_prefixed_address = dict_of_df["address"].add_prefix( + df_prefixed_address = dict_of_df["address"].drop(labels=["created_at", "last_updated"], axis=1).add_prefix( "counterparty_legal_", axis=1 ) df_cp = pd.merge( @@ -169,10 +169,10 @@ def create_dim_counterparty(dict_of_df): df_prefixed_address, left_on="legal_address_id", right_on="counterparty_legal_address_id", - how="outer", + how="inner", ) df_cp.drop( - columns=["legal_address_id", "counterparty_legal_address_id"], inplace=True + columns=["legal_address_id", "counterparty_legal_address_id", ], inplace=True ) return df_cp |