diff --git a/batch-processing-gold-2/Batch Processing - Gold - Solutions.py b/batch-processing-gold-2/Batch Processing - Gold - Solutions.py index 598e55a..2762fce 100644 --- a/batch-processing-gold-2/Batch Processing - Gold - Solutions.py +++ b/batch-processing-gold-2/Batch Processing - Gold - Solutions.py @@ -124,7 +124,7 @@ def match_start_transaction_requests_with_responses(input_df: DataFrame, join_df ########## SOLUTION ########## def match_start_transaction_requests_with_responses(input_df: DataFrame, join_df: DataFrame) -> DataFrame: ### YOUR CODE HERE - join_type: str = "inner" + join_type: str = "left" ### return input_df.\ join(join_df, input_df.message_id == join_df.message_id, join_type).\