fix: treat stream_count=0 as 'check all streams' in DynamicStreamCheckConfig

Previously, DynamicStreamCheckConfig.stream_count defaulted to 0, which
caused _check_generated_streams_availability to slice generated_streams[:0],
resulting in zero streams being checked. This meant connectors using
DynamicStreamCheckConfig without explicitly setting stream_count would
silently skip all dynamic stream availability checks.

Now, stream_count <= 0 means 'check all generated streams', which is the
expected behavior when no limit is specified.

Co-Authored-By: bot_apk <apk@cognition.ai>

Author: devin-ai-integration[bot]

airbyte_cdk/sources/declarative/checks/check_stream.py

@@ -164,8 +164,12 @@ def _check_generated_streams_availability(
         logger: logging.Logger,
         max_count: int,
     ) -> Tuple[bool, Any]:
-        """Checks availability of generated dynamic streams."""
-        for declarative_stream in generated_streams[: min(max_count, len(generated_streams))]:
+        """Checks availability of generated dynamic streams.
+
+        If max_count is 0 or negative, all generated streams are checked.
+        """
+        streams_to_check = generated_streams if max_count <= 0 else generated_streams[:max_count]
+        for declarative_stream in streams_to_check:
             stream = stream_name_to_stream[declarative_stream["name"]]
             try:
                 stream_is_available, reason = evaluate_availability(stream, logger)

unit_tests/sources/declarative/checks/test_check_stream.py

@@ -439,7 +439,7 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp
             False,
             200,
             [],
-            0,
+            1,
             id="test_check_http_dynamic_stream_and_config_dynamic_stream",
         ),
         pytest.param(
@@ -464,7 +464,7 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp
             False,
             200,
             [],
-            0,
+            1,
             id="test_check_static_streams_and_http_dynamic_stream_and_config_dynamic_stream",
         ),
         pytest.param(
@@ -487,6 +487,26 @@ def parse_response(self, response: requests.Response, **kwargs) -> Iterable[Mapp
             1,
             id="test_stream_count_gt_generated_streams",
         ),
+        pytest.param(
+            {
+                "check": {
+                    "type": "CheckStream",
+                    "dynamic_streams_check_configs": [
+                        {
+                            "type": "DynamicStreamCheckConfig",
+                            "dynamic_stream_name": "http_dynamic_stream",
+                            "stream_count": 0,
+                        },
+                    ],
+                }
+            },
+            Status.SUCCEEDED,
+            False,
+            200,
+            [],
+            1,
+            id="test_stream_count_zero_checks_all_streams",
+        ),
         pytest.param(
             {"check": {"type": "CheckStream", "stream_names": ["non_existent_stream"]}},
             Status.FAILED,