code review

Author: maxime.c

unit_tests/sources/streams/concurrent/test_default_stream.py

@@ -313,7 +313,7 @@ def test_given_unknown_error_when_reading_record_when_get_availability_then_rais
         """
         I'm not sure why we handle AirbyteTracedException but not other exceptions but this is to keep feature compatibility with HttpAvailabilityStrategy
         """
-        self._partition_generator.generate.side_effect = ValueError()
-        self._partition.read.return_value = []
+        self._partition_generator.generate.return_value = [self._partition]
+        self._partition.read.side_effect = ValueError()
         with pytest.raises(ValueError):
             self._stream.check_availability()