From 6e3e2576b584f3e2ef8147e739b0749f74bfbb23 Mon Sep 17 00:00:00 2001 From: Judah Rand <17158624+judahrand@users.noreply.github.com> Date: Mon, 21 Feb 2022 22:55:09 +0000 Subject: [PATCH] Update `test_logical_streams_from_pg_with_hard_delete_mapping` --- tests/integration/test_target_bigquery.py | 25 +++++++++++------------ 1 file changed, 12 insertions(+), 13 deletions(-) diff --git a/tests/integration/test_target_bigquery.py b/tests/integration/test_target_bigquery.py index 63b8831..00ef5b9 100644 --- a/tests/integration/test_target_bigquery.py +++ b/tests/integration/test_target_bigquery.py @@ -617,28 +617,27 @@ def test_logical_streams_from_pg_with_hard_delete_mapping(self): # ---------------------------------------------------------------------- # Check rows in table_two # ---------------------------------------------------------------------- - delete_time = datetime.datetime(2019, 10, 13, 14, 6, 31, 838000, tzinfo=timezone.utc) expected_table_two = [ {'cid': 1, 'cvarchar': "updated row", "_sdc_deleted_at": None}, {'cid': 2, 'cvarchar': 'updated row', "_sdc_deleted_at": None}, {'cid': 3, 'cvarchar': "updated row", "_sdc_deleted_at": None}, - {'cid': 4, 'cvarchar': None, "_sdc_deleted_at": delete_time}, + {'cid': 4, 'cvarchar': None, "_sdc_deleted_at": None}, {'cid': 5, 'cvarchar': "updated row", "_sdc_deleted_at": None}, - {'cid': 6, 'cvarchar': None, "_sdc_deleted_at": delete_time}, + {'cid': 6, 'cvarchar': None, "_sdc_deleted_at": None}, {'cid': 7, 'cvarchar': "updated row", "_sdc_deleted_at": None}, {'cid': 8, 'cvarchar': "updated row", "_sdc_deleted_at": None}, {'cid': 9, 'cvarchar': "updated row", "_sdc_deleted_at": None}, {'cid': 10, 'cvarchar': 'updated row', "_sdc_deleted_at": None}, - {"cid": 11, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 12, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 13, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 14, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 15, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 16, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 17, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 18, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 19, "cvarchar": None, "_sdc_deleted_at": delete_time}, - {"cid": 20, "cvarchar": None, "_sdc_deleted_at": delete_time}, + {"cid": 11, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 12, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 13, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 14, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 15, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 16, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 17, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 18, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 19, "cvarchar": None, "_sdc_deleted_at": None}, + {"cid": 20, "cvarchar": None, "_sdc_deleted_at": None}, ] # ----------------------------------------------------------------------