From f2d7ac6f27c92c183994737574d338aa383b7cb6 Mon Sep 17 00:00:00 2001 From: JYOTHINARAYANSETTY <49671483+JYOTHINARAYANSETTY@users.noreply.github.com> Date: Tue, 14 Nov 2023 13:23:28 -0500 Subject: [PATCH] Update tests/test_salesforce_switch_rep_method_incrmntl_ft.py Co-authored-by: bhtowles --- tests/test_salesforce_switch_rep_method_incrmntl_ft.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/test_salesforce_switch_rep_method_incrmntl_ft.py b/tests/test_salesforce_switch_rep_method_incrmntl_ft.py index 227ecdd9..99291cdf 100644 --- a/tests/test_salesforce_switch_rep_method_incrmntl_ft.py +++ b/tests/test_salesforce_switch_rep_method_incrmntl_ft.py @@ -73,7 +73,7 @@ def test_run(self): if record.get('action') == 'upsert'] incrmntl_primary_keys = {message[primary_key] for message in incrmntl_sync_messages} fulltbl_sync_messages = [record['data'] for record in - fulltbl_sync_records.get(stream).get('messages') + fulltbl_sync_records.get(stream, {}).get('messages') if record.get('action') == 'upsert'] filtered_fulltbl_sync_messages = [message for message in fulltbl_sync_messages if message[replication_key] >= self.start_date]