We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ba1154c commit 5ca2ddbCopy full SHA for 5ca2ddb
octavia-cli/octavia_cli/apply/resources.py
@@ -503,7 +503,9 @@ def catalog(self) -> AirbyteCatalog:
503
AirbyteCatalog: The catalog issued by schema discovery.
504
"""
505
schema = self.api_instance.discover_schema_for_source(self.source_discover_schema_request_body)
506
- return schema.catalog
+ if schema.job_info.succeeded:
507
+ return schema.catalog
508
+ raise Exception("Could not discover schema for source", self.source_discover_schema_request_body, schema.job_info.logs)
509
510
@property
511
def definition(self) -> SourceDefinitionSpecificationRead:
0 commit comments