diff --git a/gluestick/etl_utils.py b/gluestick/etl_utils.py index 6839855..db5a3b7 100644 --- a/gluestick/etl_utils.py +++ b/gluestick/etl_utils.py @@ -558,7 +558,7 @@ def get_types_from_catalog(self, catalog, stream): streams = next(c for c in catalog["streams"] if c["stream"] == stream) types = streams["schema"]["properties"] - type_mapper = {"integer": "Int64", "number": float, "boolean": bool} + type_mapper = {"integer": "Int64", "number": float, "boolean": "boolean"} dtype = {} parse_dates = []