Skip to content

Commit d14cd84

Browse files
committed
format cleanup
1 parent 164afb6 commit d14cd84

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

airbyte_cdk/connector_builder/main.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,12 @@ def handle_connector_builder_request(
9393
def handle_request(args: List[str]) -> str:
9494
command, config, catalog, state = get_config_and_catalog_from_args(args)
9595
limits = get_limits(config)
96-
source = create_source(config=config, limits=limits, catalog=catalog, state=state)
96+
source = create_source(
97+
config=config,
98+
limits=limits,
99+
catalog=catalog,
100+
state=state,
101+
)
97102
return orjson.dumps( # type: ignore[no-any-return] # Serializer.dump() always returns AirbyteMessage
98103
AirbyteMessageSerializer.dump(
99104
handle_connector_builder_request(source, command, config, catalog, state, limits)

unit_tests/connector_builder/test_connector_builder_handler.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -901,7 +901,12 @@ def test_handle_429_response():
901901

902902
limits = TestLimits()
903903
catalog = ConfiguredAirbyteCatalogSerializer.load(CONFIGURED_CATALOG)
904-
source = create_source(config=config, limits=limits, catalog=catalog, state=None)
904+
source = create_source(
905+
config=config,
906+
limits=limits,
907+
catalog=catalog,
908+
state=None,
909+
)
905910

906911
with patch("requests.Session.send", return_value=response) as mock_send:
907912
response = handle_connector_builder_request(

0 commit comments

Comments
 (0)