Fix connectors

This commit is contained in:
Weves
2023-05-16 22:41:12 -07:00
committed by Chris Weaver
parent 5ff8924a90
commit 5f7d2853b8

View File

@@ -48,8 +48,11 @@ def build_connector(
def build_pull_connector(
source: DocumentSource, connector_specific_config: dict[str, Any]
) -> PullLoader:
return _range_pull_to_pull(
build_connector(source, InputType.PULL, connector_specific_config)
connector = build_connector(source, InputType.PULL, connector_specific_config)
return (
_range_pull_to_pull(connector)
if isinstance(connector, RangePullLoader)
else connector
)