Skip to content

Commit bbaf25a

Browse files
committed
pr feedback
1 parent 5ca41a9 commit bbaf25a

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -485,7 +485,10 @@ def spec(self, logger: logging.Logger) -> ConnectorSpecification:
485485
)
486486

487487
def check(self, logger: logging.Logger, config: Mapping[str, Any]) -> AirbyteConnectionStatus:
488-
check = self._source_config["check"]
488+
check = self._source_config.get("check")
489+
if not check:
490+
raise ValueError(f"Missing 'check' component definition within the manifest.")
491+
489492
if "type" not in check:
490493
check["type"] = "CheckStream"
491494
connection_checker = self._constructor.create_component(

0 commit comments

Comments
 (0)