Skip to content

Commit fb7d1e9

Browse files
committed
fix module and classname conflicts
1 parent 711384c commit fb7d1e9

File tree

7 files changed

+11
-19
lines changed

7 files changed

+11
-19
lines changed

airbyte_cdk/sources/declarative/transformations/config_transformations/__init__.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22
# Copyright (c) 2025 Airbyte, Inc., all rights reserved.
33
#
44

5-
from .add_fields import AddFields
6-
from .remap_field import RemapField
7-
from .remove_fields import RemoveFields
5+
from .add_fields import ConfigAddFields
6+
from .remap_field import ConfigRemapField
7+
from .remove_fields import ConfigRemoveFields
88

9-
__all__ = ["RemapField", "AddFields", "RemoveFields"]
9+
__all__ = ["ConfigRemapField", "ConfigAddFields", "ConfigRemoveFields"]

airbyte_cdk/sources/declarative/transformations/config_transformations/add_fields.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,15 +34,15 @@ class ParsedAddFieldDefinition:
3434

3535

3636
@dataclass
37-
class AddFields(ConfigTransformation):
37+
class ConfigAddFields(ConfigTransformation):
3838
"""
3939
Transformation which adds fields to a config. The path of the added field can be nested. Adding nested fields will create all
4040
necessary parent objects (like mkdir -p).
4141
4242
This transformation has access to the config being transformed.
4343
4444
Examples of instantiating this transformation via YAML:
45-
- type: AddFields
45+
- type: ConfigAddFields
4646
fields:
4747
# hardcoded constant
4848
- path: ["path"]

airbyte_cdk/sources/declarative/transformations/config_transformations/remap_field.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212

1313

1414
@dataclass
15-
class RemapField(ConfigTransformation):
15+
class ConfigRemapField(ConfigTransformation):
1616
"""
1717
Transformation that remaps a field's value to another value based on a static map.
1818
"""

airbyte_cdk/sources/declarative/transformations/config_transformations/remove_fields.py

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
#
22
# Copyright (c) 2025 Airbyte, Inc., all rights reserved.
33
#
4-
import logging
54
from dataclasses import dataclass
65
from typing import Any, List, MutableMapping
76

@@ -14,11 +13,9 @@
1413
)
1514
from airbyte_cdk.sources.types import FieldPointer
1615

17-
logger = logging.getLogger("airbyte")
18-
1916

2017
@dataclass
21-
class RemoveFields(ConfigTransformation):
18+
class ConfigRemoveFields(ConfigTransformation):
2219
"""
2320
A transformation which removes fields from a config. The fields removed are designated using FieldPointers.
2421
During transformation, if a field or any of its parents does not exist in the config, no error is thrown.
@@ -67,6 +64,3 @@ def transform(
6764
dpath.delete(config, pointer)
6865
except dpath.exceptions.PathNotFound:
6966
pass
70-
except Exception as e:
71-
logger.error(f"Error removing field {pointer}: {e}")
72-
raise e

unit_tests/sources/declarative/transformations/config_transformations/test_add_fields.py renamed to unit_tests/sources/declarative/transformations/config_transformations/test_config_add_fields.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
from airbyte_cdk.sources.declarative.transformations.config_transformations.add_fields import (
88
AddedFieldDefinition,
9-
AddFields,
9+
ConfigAddFields as AddFields,
1010
)
1111

1212

unit_tests/sources/declarative/transformations/config_transformations/test_remap_field.py renamed to unit_tests/sources/declarative/transformations/config_transformations/test_config_remap_field.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import pytest
55

66
from airbyte_cdk.sources.declarative.transformations.config_transformations.remap_field import (
7-
RemapField,
7+
ConfigRemapField as RemapField,
88
)
99

1010

unit_tests/sources/declarative/transformations/config_transformations/test_remove_fields.py renamed to unit_tests/sources/declarative/transformations/config_transformations/test_config_remove_fields.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,8 @@
22
# Copyright (c) 2025 Airbyte, Inc., all rights reserved.
33
#
44

5-
import pytest
6-
75
from airbyte_cdk.sources.declarative.transformations.config_transformations.remove_fields import (
8-
RemoveFields,
6+
ConfigRemoveFields as RemoveFields,
97
)
108

119

0 commit comments

Comments
 (0)