Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Merged
merged 4 commits into from
Mar 29, 2017
Merged

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

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
1af2ca6
Track both query start time and button push time to track delay
mistercrunch Mar 28, 2017
50769c9
Fix
mistercrunch Mar 28, 2017
cbbf716
Setting the proper precision
mistercrunch Mar 29, 2017
712e22d
More logging
mistercrunch Mar 29, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
More logging
  • Loading branch information
@mistercrunch
mistercrunch committed Mar 29, 2017
commit 712e22d5a0d7062480fa92aaa2d3b257d95beeb3
5 changes: 5 additions & 0 deletions superset/db_engine_specs.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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
Expand Down