pypresto
Advanced tools
+1
-1
| Metadata-Version: 1.1 | ||
| Name: pypresto | ||
| Version: 1.0.3 | ||
| Version: 1.0.4 | ||
| Summary: Python wrapper for running queries on Presto server | ||
@@ -5,0 +5,0 @@ Home-page: https://github.com/NonWhite/pyprestowrapper |
| Metadata-Version: 1.1 | ||
| Name: pypresto | ||
| Version: 1.0.3 | ||
| Version: 1.0.4 | ||
| Summary: Python wrapper for running queries on Presto server | ||
@@ -5,0 +5,0 @@ Home-page: https://github.com/NonWhite/pyprestowrapper |
@@ -64,3 +64,3 @@ import os | ||
| def run_query(self,sql_query) : | ||
| def run_query(self,sql_query,ignore_empty=False) : | ||
| response = self.send_query(sql_query) | ||
@@ -81,8 +81,10 @@ series = [] | ||
| time.sleep(1) | ||
| elif 'columns' in response : | ||
| columns = columns or [col['name'] for col in response['columns']] | ||
| else: | ||
| #print 'Running query' | ||
| time.sleep(5) | ||
| df = pandas.DataFrame(series) | ||
| if df.empty : | ||
| df = pandas.DataFrame(series,columns=columns) | ||
| if df.empty and not ignore_empty : | ||
| raise Exception('No data returned') | ||
| return df |
+1
-1
@@ -30,3 +30,3 @@ import os | ||
| name='pypresto', | ||
| version='1.0.3', | ||
| version='1.0.4', | ||
| author='NonWhite', | ||
@@ -33,0 +33,0 @@ author_email='wperezurcia@gmail.com', |
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.
11103
1.64%119
1.71%