Track both query start time and button push time to track delay

superset/db_engine_specs.py

@@ -360,6 +360,7 @@ def extra_table_metadata(cls, database, table_name, schema_name):
     @classmethod
     def handle_cursor(cls, cursor, query, session):
         """Updates progress information"""
+        logging.info('Polling the cursor for progress')
         polled = cursor.poll()
         # poll returns dict -- JSON status information or ``None``
         # if the query is done
@@ -379,10 +380,14 @@ def handle_cursor(cls, cursor, query, session):
                 total_splits = float(stats.get('totalSplits'))
                 if total_splits and completed_splits:
                     progress = 100 * (completed_splits / total_splits)
+                    logging.info(
+                        'Query progress: {} / {} '
+                        'splits'.format(completed_splits, total_splits))
                     if progress > query.progress:
                         query.progress = progress
                     session.commit()
             time.sleep(1)
+            logging.info('Polling the cursor for progress')
             polled = cursor.poll()
 
     @classmethod

superset/migrations/versions/a6c18f869a4e_query_start_running_time.py

@@ -0,0 +1,26 @@
+"""query.start_running_time
+
+Revision ID: a6c18f869a4e
+Revises: 979c03af3341
+Create Date: 2017-03-28 11:28:41.387182
+
+"""
+from alembic import op
+import sqlalchemy as sa
+
+# revision identifiers, used by Alembic.
+revision = 'a6c18f869a4e'
+down_revision = '979c03af3341'
+
+
+
+def upgrade():
+    op.add_column(
+        'query',
+        sa.Column('start_running_time',
+        sa.Numeric(precision=20, scale=6),
+        nullable=True))
+
+
+def downgrade():
+    op.drop_column('query', 'start_running_time')

superset/models/core.py

@@ -830,6 +830,7 @@ class Query(Model):
     # Using Numeric in place of DateTime for sub-second precision
     # stored as seconds since epoch, allowing for milliseconds
     start_time = Column(Numeric(precision=3))
+    start_running_time = Column(Numeric(precision=3))
     end_time = Column(Numeric(precision=3))
     changed_on = Column(
         DateTime, default=datetime.utcnow, onupdate=datetime.utcnow, nullable=True)

superset/sql_lab.py

@@ -104,12 +104,17 @@ def handle_error(msg):
         handle_error(msg)
 
     query.executed_sql = executed_sql
-    logging.info("Running query: \n{}".format(executed_sql))
+    query.status = QueryStatus.RUNNING
+    query.start_running_time = utils.now_as_float()
+    session.merge(query)
+    session.commit()
+    logging.info("Set query to 'running'")
+
     engine = database.get_sqla_engine(schema=query.schema)
     conn = engine.raw_connection()
     cursor = conn.cursor()
+    logging.info("Running query: \n{}".format(executed_sql))
     try:
-        print(query.executed_sql)
         logging.info(query.executed_sql)
         cursor.execute(
             query.executed_sql, **db_engine_spec.cursor_execute_kwargs)
@@ -118,8 +123,6 @@ def handle_error(msg):
         conn.close()
         handle_error(db_engine_spec.extract_error_message(e))
 
-    query.status = QueryStatus.RUNNING
-    session.flush()
     try:
         logging.info("Handling cursor")
         db_engine_spec.handle_cursor(cursor, query, session)
@@ -156,6 +159,7 @@ def handle_error(msg):
             schema=database.force_ctas_schema
         ))
     query.end_time = utils.now_as_float()
+    session.merge(query)
     session.flush()
 
     payload = {
@@ -173,7 +177,7 @@ def handle_error(msg):
         results_backend.set(key, zlib.compress(payload))
         query.results_key = key
 
-    session.flush()
+    session.merge(query)
     session.commit()
 
     if return_results: