diff --git a/singer_sdk/tap_base.py b/singer_sdk/tap_base.py index 6e7220eda..9a1b5ccb7 100644 --- a/singer_sdk/tap_base.py +++ b/singer_sdk/tap_base.py @@ -380,6 +380,7 @@ def sync_all(self) -> None: stream.sync() stream.finalize_state_progress_markers() + stream._write_state_message() # this second loop is needed for all streams to print out their costs # including child streams which are otherwise skipped in the loop above diff --git a/tests/core/test_countries_sync.py b/tests/core/test_countries_sync.py index 9161e2c06..6022d0002 100644 --- a/tests/core/test_countries_sync.py +++ b/tests/core/test_countries_sync.py @@ -130,4 +130,4 @@ def tally_messages(messages: list) -> Counter: assert counter["SCHEMA", "countries"] == 1 assert counter["BATCH", "countries"] == 1 - assert counter[("STATE",)] == 2 + assert counter[("STATE",)] == 4