diff --git a/airbyte_cdk/sources/declarative/transformations/config_transformations/remap_field.py b/airbyte_cdk/sources/declarative/transformations/config_transformations/remap_field.py index ac7a62d24..6efdbef71 100644 --- a/airbyte_cdk/sources/declarative/transformations/config_transformations/remap_field.py +++ b/airbyte_cdk/sources/declarative/transformations/config_transformations/remap_field.py @@ -59,7 +59,7 @@ def transform( field_name = path_components[-1] - mapping = self._map.eval(config=self.config) + mapping = self._map.eval(config=self.config or config) if field_name in current and current[field_name] in mapping: current[field_name] = mapping[current[field_name]]