Merge branch 'devin/1756425696-jsonschema-version-pin' of https://git-manager.devin.ai/proxy/github.com/airbytehq/airbyte-python-cdk into devin/1756425696-jsonschema-version-pin

Author: devin-ai-integration[bot]

airbyte_cdk/connector_builder/connector_builder_handler.py

@@ -62,11 +62,13 @@ def should_normalize_manifest(config: Mapping[str, Any]) -> bool:
 
 def create_source(
     config: Mapping[str, Any],
-    limits: TestLimits,
-    catalog: Optional[ConfiguredAirbyteCatalog],
-    state: Optional[List[AirbyteStateMessage]],
+    limits: TestLimits | None = None,
+    catalog: ConfiguredAirbyteCatalog | None = None,
+    state: List[AirbyteStateMessage] | None = None,
 ) -> ConcurrentDeclarativeSource[Optional[List[AirbyteStateMessage]]]:
     manifest = config["__injected_declarative_manifest"]
+    catalog = catalog or None
+    state = state or []
 
     # We enforce a concurrency level of 1 so that the stream is processed on a single thread
     # to retain ordering for the grouping of the builder message responses.

airbyte_cdk/connector_builder/main.py

@@ -93,7 +93,12 @@ def handle_connector_builder_request(
 def handle_request(args: List[str]) -> str:
     command, config, catalog, state = get_config_and_catalog_from_args(args)
     limits = get_limits(config)
-    source = create_source(config=config, limits=limits, catalog=catalog, state=state)
+    source = create_source(
+        config=config,
+        limits=limits,
+        catalog=catalog,
+        state=state,
+    )
     return orjson.dumps(  # type: ignore[no-any-return] # Serializer.dump() always returns AirbyteMessage
         AirbyteMessageSerializer.dump(
             handle_connector_builder_request(source, command, config, catalog, state, limits)

unit_tests/connector_builder/test_connector_builder_handler.py

@@ -901,7 +901,12 @@ def test_handle_429_response():
 
     limits = TestLimits()
     catalog = ConfiguredAirbyteCatalogSerializer.load(CONFIGURED_CATALOG)
-    source = create_source(config=config, limits=limits, catalog=catalog, state=None)
+    source = create_source(
+        config=config,
+        limits=limits,
+        catalog=catalog,
+        state=None,
+    )
 
     with patch("requests.Session.send", return_value=response) as mock_send:
         response = handle_connector_builder_request(