Fix test

Author: maxime.c

unit_tests/sources/streams/test_stream_read.py

@@ -114,6 +114,7 @@ def read_records(
 
 
 class MockConcurrentCursor(Cursor):
+
     _state: MutableMapping[str, Any]
     _message_repository: MessageRepository
 
@@ -147,6 +148,9 @@ def close_partition(self, partition: Partition) -> None:
     def ensure_at_least_one_state_emitted(self) -> None:
         pass
 
+    def should_be_synced(self, record: Record) -> bool:
+        return True
+
 
 def _stream(slice_to_partition_mapping, slice_logger, logger, message_repository, json_schema=None):
     return _MockStream(slice_to_partition_mapping, json_schema=json_schema)