fix different stream checking logic and add parameter to async retriever

Author: lmossman

airbyte_cdk/connector_builder/test_reader/helpers.py

@@ -288,11 +288,14 @@ def is_page_http_request_for_different_stream(
     Returns:
         bool: True if the JSON message is a page HTTP request for a different stream, False otherwise.
     """
-    return (
-        json_message is not None
-        and is_page_http_request(json_message)
-        and json_message.get("airbyte_cdk", {}).get("stream", {}).get("name", "") != stream_name
-    )
+    if not json_message or not is_page_http_request(json_message):
+        return False
+
+    message_stream_name = json_message.get("airbyte_cdk", {}).get("stream", {}).get("name", None)
+    if message_stream_name is None:
+        return False
+
+    return message_stream_name != stream_name
 
 
 def is_page_http_request(json_message: Optional[Dict[str, Any]]) -> bool:

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -3858,6 +3858,7 @@ def create_config_components_resolver(
         self,
         model: ConfigComponentsResolverModel,
         config: Config,
+        stream_name: Optional[str] = None,
     ) -> Any:
         model_stream_configs = (
             model.stream_config if isinstance(model.stream_config, list) else [model.stream_config]