You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@superset.apache.org by gr...@apache.org on 2019/05/24 00:39:46 UTC
[incubator-superset] branch master updated: [sql lab]revert #4833
(#7498)
This is an automated email from the ASF dual-hosted git repository.
graceguo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-superset.git
The following commit(s) were added to refs/heads/master by this push:
new 2014329 [sql lab]revert #4833 (#7498)
2014329 is described below
commit 20143293eb9cac93a1692dcd552be5cb48b5d3e9
Author: Grace Guo <gr...@airbnb.com>
AuthorDate: Thu May 23 17:39:40 2019 -0700
[sql lab]revert #4833 (#7498)
---
superset/views/core.py | 47 ++++++++---------------------------------------
1 file changed, 8 insertions(+), 39 deletions(-)
diff --git a/superset/views/core.py b/superset/views/core.py
index 0aedb6b..883a2d9 100755
--- a/superset/views/core.py
+++ b/superset/views/core.py
@@ -21,7 +21,6 @@ import inspect
import logging
import os
import re
-import time
import traceback
from typing import List # noqa: F401
from urllib import parse
@@ -37,8 +36,7 @@ from flask_babel import gettext as __
from flask_babel import lazy_gettext as _
import pandas as pd
import simplejson as json
-import sqlalchemy as sqla
-from sqlalchemy import and_, create_engine, MetaData, or_, select, update
+from sqlalchemy import and_, create_engine, MetaData, or_, select
from sqlalchemy.engine.url import make_url
from sqlalchemy.exc import IntegrityError
from werkzeug.routing import BaseConverter
@@ -1846,7 +1844,7 @@ class Superset(BaseSupersetView):
M.Slice.id == M.Log.slice_id,
)
.filter(
- sqla.and_(
+ and_(
~M.Log.action.in_(('queries', 'shortner', 'sql_json')),
M.Log.user_id == user_id,
),
@@ -1916,7 +1914,7 @@ class Superset(BaseSupersetView):
)
.join(
models.FavStar,
- sqla.and_(
+ and_(
models.FavStar.user_id == int(user_id),
models.FavStar.class_name == 'Dashboard',
models.Dashboard.id == models.FavStar.obj_id,
@@ -1954,7 +1952,7 @@ class Superset(BaseSupersetView):
Dash,
)
.filter(
- sqla.or_(
+ or_(
Dash.created_by_fk == user_id,
Dash.changed_by_fk == user_id,
),
@@ -1987,13 +1985,13 @@ class Superset(BaseSupersetView):
db.session.query(Slice,
FavStar.dttm).join(
models.FavStar,
- sqla.and_(
+ and_(
models.FavStar.user_id == int(user_id),
models.FavStar.class_name == 'slice',
models.Slice.id == models.FavStar.obj_id,
),
isouter=True).filter(
- sqla.or_(
+ or_(
Slice.created_by_fk == user_id,
Slice.changed_by_fk == user_id,
FavStar.user_id == user_id,
@@ -2024,7 +2022,7 @@ class Superset(BaseSupersetView):
qry = (
db.session.query(Slice)
.filter(
- sqla.or_(
+ or_(
Slice.created_by_fk == user_id,
Slice.changed_by_fk == user_id,
),
@@ -2056,7 +2054,7 @@ class Superset(BaseSupersetView):
)
.join(
models.FavStar,
- sqla.and_(
+ and_(
models.FavStar.user_id == int(user_id),
models.FavStar.class_name == 'slice',
models.Slice.id == models.FavStar.obj_id,
@@ -2803,35 +2801,6 @@ class Superset(BaseSupersetView):
.all()
)
dict_queries = {q.client_id: q.to_dict() for q in sql_queries}
-
- now = int(round(time.time() * 1000))
-
- unfinished_states = [
- QueryStatus.PENDING,
- QueryStatus.RUNNING,
- ]
-
- queries_to_timeout = [
- client_id for client_id, query_dict in dict_queries.items()
- if (
- query_dict['state'] in unfinished_states and (
- now - query_dict['startDttm'] >
- config.get('SQLLAB_ASYNC_TIME_LIMIT_SEC') * 1000
- )
- )
- ]
-
- if queries_to_timeout:
- update(Query).where(
- and_(
- Query.user_id == g.user.get_id(),
- Query.client_id in queries_to_timeout,
- ),
- ).values(state=QueryStatus.TIMED_OUT)
-
- for client_id in queries_to_timeout:
- dict_queries[client_id]['status'] = QueryStatus.TIMED_OUT
-
return json_success(
json.dumps(dict_queries, default=utils.json_int_dttm_ser))