diff --git a/airflow/migrations/versions/cc1e65623dc7_add_max_tries_column_to_task_instance.py b/airflow/migrations/versions/cc1e65623dc7_add_max_tries_column_to_task_instance.py index 68228f7219a87..61ad3ef57069d 100644 --- a/airflow/migrations/versions/cc1e65623dc7_add_max_tries_column_to_task_instance.py +++ b/airflow/migrations/versions/cc1e65623dc7_add_max_tries_column_to_task_instance.py @@ -35,7 +35,6 @@ import sqlalchemy as sa from airflow import settings from airflow.models import DagBag -from airflow.utils.sqlalchemy import UtcDateTime from sqlalchemy import ( Column, Integer, String) @@ -52,7 +51,7 @@ class TaskInstance(Base): task_id = Column(String(ID_LEN), primary_key=True) dag_id = Column(String(ID_LEN), primary_key=True) - execution_date = Column(UtcDateTime, primary_key=True) + execution_date = Column(sa.DateTime, primary_key=True) max_tries = Column(Integer) try_number = Column(Integer, default=0)