#2656 bug: Stream map defined using record or _ syntax fails to look up correct data type Issue created by dluo-sig Another similar issue in CustomStreamMap: existing_schema: dict = ( # Use transformed schema if available transformed_schema["properties"].get(prop_key, {}) # ...or original schema for passthrough or self.raw_schema["properties"].get(prop_def, {}) ) If the stream map is defined using

_['columnName']

or

record['columnName']

, the type mapping falls back to string because it doesn't look at the underlying column name, but rather treats the entire expression as the column that it's searching for.

prop_def

should check for that specification and pass through the appropriate column name. Originally posted by @dluo-sig in #1695 (comment) meltano/sdk