1
0
mirror of synced 2025-12-23 21:03:15 -05:00

source salesforce: fix build (#13374)

This commit is contained in:
Denis Davydov
2022-06-01 17:31:07 +03:00
committed by GitHub
parent dc3878d15a
commit 006d3efec6

View File

@@ -87,6 +87,13 @@ def test_failed_jobs_with_successful_switching(caplog, input_sandbox_config, str
m.register_uri("DELETE", job_matcher, json={})
with caplog.at_level(logging.WARNING):
loaded_record_ids = set(record["Id"] for record in stream.read_records(sync_mode=SyncMode.full_refresh))
for i, log_message in enumerate(log_messages, 1):
assert log_message in caplog.records[-i].message
caplog_rec_counter = len(caplog.records) - 1
for log_message in log_messages:
for index in range(caplog_rec_counter, -1, -1):
if log_message in caplog.records[index].message:
caplog_rec_counter = index - 1
break
else:
pytest.fail(f"{log_message} is missing from captured log")
assert loaded_record_ids == expected_record_ids