diff --git a/tap_redshift/__init__.py b/tap_redshift/__init__.py index 85305f5..d702392 100644 --- a/tap_redshift/__init__.py +++ b/tap_redshift/__init__.py @@ -277,7 +277,7 @@ def get_stream_version(tap_stream_id, state): def row_to_record(catalog_entry, version, row, columns, time_extracted): row_to_persist = () for idx, elem in enumerate(row): - if isinstance(elem, datetime.date): + if isinstance(elem, datetime.datetime): elem = elem.isoformat('T') + 'Z' row_to_persist += (elem,) return singer.RecordMessage(