From 4c810fe57a5ae65f431b8c4812bcacdacb3d4701 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Sun, 20 Jun 2021 18:56:12 -0500 Subject: [PATCH] bug fix --- transport/sql.py | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/transport/sql.py b/transport/sql.py index 198c3f3..6e526cc 100644 --- a/transport/sql.py +++ b/transport/sql.py @@ -226,12 +226,7 @@ class BQReader(BigQuery,Reader) : SQL += " LIMIT "+str(_args['limit']) if (':dataset' in SQL or ':DATASET' in SQL) and self.dataset: SQL = SQL.replace(':dataset',self.dataset).replace(':DATASET',self.dataset) - _info = {'credentials':self.credentials,'dialect':'standard'} - if 'dtypes' in _args or self.dtypes : - if not self.dtypes : - self.dtypes = _args ['dtypes'] if 'dtypes' in _args else None - if self.dtypes : - _info['dtypes'] = self.dtypes + _info = {'credentials':self.credentials,'dialect':'standard'} return pd.read_gbq(SQL,**_info) if SQL else None # return pd.read_gbq(SQL,credentials=self.credentials,dialect='standard') if SQL else None class BQWriter(BigQuery,Writer):