diff --git a/migrations/versions/0439_add_index_n_history.py b/migrations/versions/0439_add_index_n_history.py
index 7d0c4cfef0..ed989a6273 100644
--- a/migrations/versions/0439_add_index_n_history.py
+++ b/migrations/versions/0439_add_index_n_history.py
@@ -13,10 +13,18 @@
 down_revision = "0438_sms_templates_msgs_left"
 
 
+def index_exists(name):
+    connection = op.get_bind()
+    result = connection.execute(
+        "SELECT exists(SELECT 1 from pg_indexes where indexname = '{}') as ix_exists;".format(name)
+    ).first()
+    return result.ix_exists
+
+
 # option 1
 def upgrade():
     op.execute("COMMIT")
-    if not op.get_context().dialect.has_index(op, "ix_notification_history_created_by_id", "notification_history"):
+    if not index_exists("ix_notifications_created_by_id"):
         op.create_index(
             op.f("ix_notification_history_created_by_id"), "notification_history", ["created_by_id"], postgresql_concurrently=True
         )