diff --git a/lib/blazer/adapters/athena_adapter.rb b/lib/blazer/adapters/athena_adapter.rb index 33ba6a5ef..d62bc49dc 100644 --- a/lib/blazer/adapters/athena_adapter.rb +++ b/lib/blazer/adapters/athena_adapter.rb @@ -60,7 +60,7 @@ def run_statement(statement, comment) column_types.each_with_index do |ct, i| # TODO more column_types case ct - when "timestamp" + when "timestamp", "timestamp with time zone" rows.each do |row| row[i] &&= utc.parse(row[i]) end