diff --git a/setup.py b/setup.py index d4ab7442..41aed1bb 100644 --- a/setup.py +++ b/setup.py @@ -26,7 +26,6 @@ requirements = [ 'urllib3>=1.9', - "pandas>=1.2.2, <1.3", ] diff --git a/src/crate/client/cursor.py b/src/crate/client/cursor.py index c8f6837e..ba5982f0 100644 --- a/src/crate/client/cursor.py +++ b/src/crate/client/cursor.py @@ -21,7 +21,7 @@ from .exceptions import ProgrammingError import warnings -import pandas as pd +from datetime import datetime class Cursor(object): @@ -72,7 +72,10 @@ def _transform_date_columns(row, gen_flags): Generates iterates over each value from a row and converts timestamps to pandas TIMESTAMP """ for value in row: - flag = next(gen_flags) + try: + flag = next(gen_flags) + except StopIteration: + break if not flag or value is None: yield value @@ -80,7 +83,7 @@ def _transform_date_columns(row, gen_flags): if value < 0: yield None else: - value = pd.Timestamp(float(str(value)[0:13]), unit='ms') + value = datetime.fromtimestamp(value/1000) yield value def executemany(self, sql, seq_of_parameters):