Skip to content

Commit

Permalink
Update test_logical_streams_from_pg_with_hard_delete_mapping
Browse files Browse the repository at this point in the history
  • Loading branch information
judahrand committed Feb 21, 2022
1 parent e440b8b commit 6e3e257
Showing 1 changed file with 12 additions and 13 deletions.
25 changes: 12 additions & 13 deletions tests/integration/test_target_bigquery.py
Original file line number Diff line number Diff line change
Expand Up @@ -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},
]

# ----------------------------------------------------------------------
Expand Down

0 comments on commit 6e3e257

Please sign in to comment.