diff --git a/src/rockset_sqlalchemy/sqlalchemy/dialect.py b/src/rockset_sqlalchemy/sqlalchemy/dialect.py
index 85da2bd..bac1f39 100644
--- a/src/rockset_sqlalchemy/sqlalchemy/dialect.py
+++ b/src/rockset_sqlalchemy/sqlalchemy/dialect.py
@@ -102,6 +102,8 @@ def _get_table_columns(self, connection, table_name, schema):
                             field_type, fields[0], schema, table_name
                         )
                     )
+                if field[0] == "_event_time":
+                    field_type = "timestamp"
                 columns.append(
                     {
                         "name": field[0],