def METHOD_NAME(self):
    # Select only the expected streams tables
    expected_streams = self.streams_to_test()
    conn_id = connections.ensure_connection(self)
    found_catalogs = self.run_and_verify_check_mode(conn_id)
    catalog_entries = [ce for ce in found_catalogs if ce['tap_stream_id'] in expected_streams]
    for catalog_entry in catalog_entries:
        stream_schema = menagerie.get_annotated_schema(conn_id, catalog_entry['stream_id'])
        connections.select_catalog_and_fields_via_metadata(
            conn_id,
            catalog_entry,
            stream_schema
        )
    sync_record_count = self.run_and_verify_sync(conn_id)
    sync_records = runner.get_records_from_target_output()
    # Test by stream
    for stream in expected_streams:
        with self.subTest(stream=stream):
            record_count = sync_record_count.get(stream, 0)
            sync_messages = sync_records.get(stream, {'messages': []}).get('messages')
            primary_keys = self.expected_primary_keys().get(stream)
            # Verify the sync meets or exceeds the default record count
            stream_page_size = self.expected_page_limits()[stream]
            self.assertLess(stream_page_size, record_count)
            # Verify we did not duplicate any records across pages
            records_pks_set = {tuple([message.get('data').get(primary_key)
                                      for primary_key in primary_keys])
                               for message in sync_messages}
            records_pks_list = [tuple([message.get('data').get(primary_key)
                                       for primary_key in primary_keys])
                                for message in sync_messages]
            # records_pks_list = [message.get('data').get(primary_key) for message in sync_messages]
            self.assertCountEqual(records_pks_set, records_pks_list,
                                  msg=f"We have duplicate records for {stream}")