diff --git a/lib/blazer/adapters/athena_adapter.rb b/lib/blazer/adapters/athena_adapter.rb index 31c118ce0..4293bc9da 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