diff --git a/ingen/reader/file_reader.py b/ingen/reader/file_reader.py index 195434dc..49a0d245 100644 --- a/ingen/reader/file_reader.py +++ b/ingen/reader/file_reader.py @@ -33,6 +33,10 @@ def read(self, src): names=config['all_cols'], dtype=dtype, encoding=encoding) + + if src.get('convert_dtypes',False): + result=result.convert_dtypes() + except TypeError: logging.error(self.DTYPE_LOG_MSG) raise @@ -41,7 +45,6 @@ def read(self, src): result = pd.DataFrame(columns=config['all_cols']) else: raise - return result