From 102575af5e1ac3f12b3f7e1c459a3a06bc5ec80a Mon Sep 17 00:00:00 2001 From: Ellie Date: Tue, 27 Aug 2024 17:24:47 +0100 Subject: amend to inner join --- src/dataframes.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src') 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 -- cgit v1.2.3