@@ -1158,29 +1158,17 @@ async def test_airbyte_trace_message_on_failure(self, connector_config, inputs:
1158
1158
1159
1159
invalid_configured_catalog = ConfiguredAirbyteCatalog (
1160
1160
streams = [
1161
- # Create ConfiguredAirbyteStream without validation.
1162
- #
1163
- # Care must be taken for the created object to be valid regardless.
1164
- # Connectors using the Bulk CDK will perform schema validation
1165
- # https://github.com/airbytehq/airbyte/blob/master/airbyte-cdk/bulk/core/base/src/main/kotlin/io/airbyte/cdk/command/ConfiguredCatalogFactory.kt#L29
1161
+ # Create ConfiguredAirbyteStream which is deliberately invalid
1162
+ # with regard to the Airbyte Protocol.
1163
+ # This should cause the connector to fail.
1166
1164
ConfiguredAirbyteStream .construct (
1167
1165
stream = AirbyteStream (
1168
1166
name = "__AIRBYTE__stream_that_does_not_exist" ,
1169
- namespace = "__AIRBYTE__namespace_that_does_not_exist" ,
1170
1167
json_schema = {"type" : "object" , "properties" : {"f1" : {"type" : "string" }}},
1171
1168
supported_sync_modes = [SyncMode .full_refresh ],
1172
- source_defined_primary_key = [],
1173
- source_defined_cursor = False ,
1174
- default_cursor_field = [],
1175
- is_resumable = False ,
1176
1169
),
1177
- sync_mode = SyncMode .full_refresh ,
1178
- destination_sync_mode = DestinationSyncMode .append ,
1179
- primary_key = [],
1180
- cursor_field = [],
1181
- minimum_generation_id = 1 ,
1182
- generation_id = 1 ,
1183
- sync_id = 1 ,
1170
+ sync_mode = "INVALID" ,
1171
+ destination_sync_mode = "INVALID" ,
1184
1172
)
1185
1173
]
1186
1174
)
0 commit comments