|
226 | 226 | DynamicStreamCheckConfig as DynamicStreamCheckConfigModel, |
227 | 227 | ) |
228 | 228 | from airbyte_cdk.sources.declarative.models.declarative_component_schema import ( |
229 | | - EmitPartialRecordMergeStrategy |
| 229 | + EmitPartialRecordMergeStrategy as EmitPartialRecordMergeStrategyModel, |
230 | 230 | ) |
231 | 231 | from airbyte_cdk.sources.declarative.models.declarative_component_schema import ( |
232 | 232 | ExponentialBackoffStrategy as ExponentialBackoffStrategyModel, |
|
394 | 394 | from airbyte_cdk.sources.declarative.models.declarative_component_schema import ( |
395 | 395 | UnlimitedCallRatePolicy as UnlimitedCallRatePolicyModel, |
396 | 396 | ) |
397 | | -from airbyte_cdk.sources.declarative.models.declarative_component_schema import ( |
398 | | - ValueType |
399 | | -) |
| 397 | +from airbyte_cdk.sources.declarative.models.declarative_component_schema import ValueType |
400 | 398 | from airbyte_cdk.sources.declarative.models.declarative_component_schema import ( |
401 | 399 | WaitTimeFromHeader as WaitTimeFromHeaderModel, |
402 | 400 | ) |
@@ -625,7 +623,7 @@ def _init_mappings(self) -> None: |
625 | 623 | DefaultErrorHandlerModel: self.create_default_error_handler, |
626 | 624 | DefaultPaginatorModel: self.create_default_paginator, |
627 | 625 | DpathExtractorModel: self.create_dpath_extractor, |
628 | | - EmitPartialRecordMergeStrategy: self.create_emit_partial_record, |
| 626 | + EmitPartialRecordMergeStrategyModel: self.create_emit_partial_record, |
629 | 627 | ResponseToFileExtractorModel: self.create_response_to_file_extractor, |
630 | 628 | ExponentialBackoffStrategyModel: self.create_exponential_backoff_strategy, |
631 | 629 | SessionTokenAuthenticatorModel: self.create_session_token_authenticator, |
|
0 commit comments