Skip to content

Commit b202be8

Browse files
author
Oleksandr Bazarnov
committed
updated
1 parent b0cbb09 commit b202be8

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

airbyte_cdk/connector_builder/connector_builder_handler.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@ def should_migrate_manifest(config: Mapping[str, Any]) -> bool:
6565
"""
6666
return config.get("__should_migrate", False)
6767

68+
6869
def should_normalize_manifest(config: Mapping[str, Any]) -> bool:
6970
"""
7071
Check if the manifest should be normalized.

airbyte_cdk/sources/declarative/manifest_declarative_source.py

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ def __init__(
106106
component_factory: optional factory if ModelToComponentFactory's default behavior needs to be tweaked.
107107
normalize_manifest: Optional flag to indicate if the manifest should be normalized.
108108
"""
109-
self.logger = logging.getLogger(f"airbyte.{self.name}")
109+
self.logger = logging.getLogger(f"airbyte.{self.name}")
110110
self._should_normalize = normalize_manifest
111111
self._should_migrate = migrate_manifest
112112
self._declarative_component_schema = _get_declarative_component_schema()
@@ -128,7 +128,7 @@ def __init__(
128128
AlwaysLogSliceLogger() if emit_connector_builder_messages else DebugSliceLogger()
129129
)
130130
self._config = config or {}
131-
131+
132132
# resolve all components in the manifest
133133
self._source_config = self._pre_process_manifest(dict(source_config))
134134
# validate resolved manifest against the declarative component schema
@@ -170,9 +170,8 @@ def _pre_process_manifest(self, manifest: Dict[str, Any]) -> Dict[str, Any]:
170170
propagated_manifest = ManifestComponentTransformer().propagate_types_and_parameters(
171171
"", resolved_manifest, {}
172172
)
173-
173+
174174
return propagated_manifest
175-
176175

177176
def _post_process_manifest(self) -> None:
178177
"""
@@ -185,8 +184,6 @@ def _post_process_manifest(self) -> None:
185184
# apply manifest normalization, if required
186185
self._normalize_manifest()
187186

188-
189-
190187
def _normalize_manifest(self) -> None:
191188
"""
192189
This method is used to normalize the manifest. It should be called after the manifest has been validated.
@@ -203,7 +200,7 @@ def _migrate_manifest(self) -> None:
203200
"""
204201
This method is used to migrate the manifest. It should be called after the manifest has been validated.
205202
The migration is done in place, so the original manifest is modified.
206-
203+
207204
The original manifest is returned if any error occurs during migration.
208205
"""
209206
if self._should_migrate:

0 commit comments

Comments
 (0)