Skip to content

Commit 1d908a4

Browse files
committed
fix errors
1 parent 9cc4d11 commit 1d908a4

File tree

3 files changed

+14
-7
lines changed

3 files changed

+14
-7
lines changed

airbyte_cdk/sources/declarative/declarative_component_schema.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3806,7 +3806,7 @@ definitions:
38063806
config_normalization_rules:
38073807
title: Config Normalization Rules
38083808
type: object
3809-
additional_properties: false
3809+
additionalProperties: false
38103810
properties:
38113811
config_migrations:
38123812
title: Config Migrations
@@ -4340,7 +4340,7 @@ definitions:
43404340
properties:
43414341
type:
43424342
type: string
4343-
enum: [RemapField]
4343+
enum: [ConfigRemapField]
43444344
map:
43454345
title: Value Mapping
43464346
description: A mapping of original values to new values. When a field value matches a key in this map, it will be replaced with the corresponding value.

airbyte_cdk/sources/declarative/models/declarative_component_schema.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1549,7 +1549,7 @@ class ValidateAdheresToSchema(BaseModel):
15491549

15501550

15511551
class ConfigRemapField(BaseModel):
1552-
type: Literal["RemapField"]
1552+
type: Literal["ConfigRemapField"]
15531553
map: Union[Dict[str, Any], str] = Field(
15541554
...,
15551555
description="A mapping of original values to new values. When a field value matches a key in this map, it will be replaced with the corresponding value.",
@@ -2105,6 +2105,9 @@ class ConfigMigration(BaseModel):
21052105

21062106

21072107
class ConfigNormalizationRules(BaseModel):
2108+
class Config:
2109+
extra = Extra.forbid
2110+
21082111
config_migrations: Optional[List[ConfigMigration]] = Field(
21092112
None,
21102113
description="The discrete migrations that will be applied on the incoming config. Each migration will be applied in the order they are defined.",

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -833,7 +833,7 @@ def create_config_migration(
833833
)
834834

835835
def create_config_add_fields(
836-
self, model: ConfigAddFieldsModel, config: Config
836+
self, model: ConfigAddFieldsModel, config: Config, **kwargs: Any
837837
) -> ConfigAddFields:
838838
fields = [self._create_component_from_model(field, config) for field in model.fields]
839839
return ConfigAddFields(
@@ -842,14 +842,18 @@ def create_config_add_fields(
842842
)
843843

844844
@staticmethod
845-
def create_config_remove_fields(model: ConfigRemoveFieldsModel) -> ConfigRemoveFields:
845+
def create_config_remove_fields(
846+
model: ConfigRemoveFieldsModel, config: Config, **kwargs: Any
847+
) -> ConfigRemoveFields:
846848
return ConfigRemoveFields(
847849
field_pointers=model.field_pointers,
848850
condition=model.condition or "",
849851
)
850852

851853
@staticmethod
852-
def create_config_remap_field(model: ConfigRemapFieldModel, config: Config) -> ConfigRemapField:
854+
def create_config_remap_field(
855+
model: ConfigRemapFieldModel, config: Config, **kwargs: Any
856+
) -> ConfigRemapField:
853857
mapping = cast(Mapping[str, Any], model.map)
854858
return ConfigRemapField(
855859
map=mapping,
@@ -877,7 +881,7 @@ def create_predicate_validator(
877881

878882
@staticmethod
879883
def create_validate_adheres_to_schema(
880-
model: ValidateAdheresToSchemaModel,
884+
model: ValidateAdheresToSchemaModel, config: Config, **kwargs: Any
881885
) -> ValidateAdheresToSchema:
882886
base_schema = cast(Mapping[str, Any], model.base_schema)
883887
return ValidateAdheresToSchema(

0 commit comments

Comments
 (0)