diff --git a/superset/sql_lab.py b/superset/sql_lab.py
index f9566d3c430fb..aeb71f6b79a0e 100644
--- a/superset/sql_lab.py
+++ b/superset/sql_lab.py
@@ -168,9 +168,6 @@ def handle_error(msg):
     session.merge(query)
     session.commit()
     logging.info("Set query to 'running'")
-
-    engine = database.get_sqla_engine(
-        schema=query.schema, nullpool=not ctask.request.called_directly, user_name=user_name)
     try:
         engine = database.get_sqla_engine(
             schema=query.schema, nullpool=not ctask.request.called_directly, user_name=user_name)