diff options
| author | Ellie <ecsymonds@gmail.com> | 2024-08-27 17:24:47 +0100 |
|---|---|---|
| committer | Ellie <ecsymonds@gmail.com> | 2024-08-28 09:22:54 +0100 |
| commit | 102575af5e1ac3f12b3f7e1c459a3a06bc5ec80a (patch) | |
| tree | 61e2ce4716550c985dba5e1cafe4b9bb05639097 /src | |
| parent | f8988db9372802053db60e311960f5da4defba02 (diff) | |
| download | de-project-bentley-102575af5e1ac3f12b3f7e1c459a3a06bc5ec80a.tar.gz de-project-bentley-102575af5e1ac3f12b3f7e1c459a3a06bc5ec80a.zip | |
amend to inner join
Diffstat (limited to 'src')
| -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 |