Skip to content

Commit

Permalink
Small fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
betodealmeida committed May 10, 2022
1 parent c84c99f commit ab419a1
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions superset/sql_lab.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@
import msgpack
import pyarrow as pa
import simplejson as json
import sqlparse
from celery import Task
from celery.exceptions import SoftTimeLimitExceeded
from flask import g
Expand Down Expand Up @@ -197,19 +196,18 @@ def execute_sql_statement( # pylint: disable=too-many-arguments,too-many-locals
database: Database = query.database
db_engine_spec = database.db_engine_spec

parsed_query = ParsedQuery(sql_statement)
if is_feature_enabled("RLS_IN_SQLLAB"):
# Insert any applicable RLS predicates
parsed_query = ParsedQuery(
str(
insert_rls(
sqlparse.parse(sql_statement)[0],
parsed_query._parsed[0], # pylint: disable=protected-access
database.id,
query.schema,
)
)
)
else:
parsed_query = ParsedQuery(sql_statement)

sql = parsed_query.stripped()
# This is a test to see if the query is being
Expand Down Expand Up @@ -389,7 +387,7 @@ def execute_sql_statements( # pylint: disable=too-many-arguments, too-many-loca
stats_logger.timing("sqllab.query.time_pending", now_as_float() - start_time)

if not hasattr(g, "user"):
# pylint: disable=assigning-non-slot)
# pylint: disable=assigning-non-slot
g.user = security_manager.find_user(username=user_name)

query = get_query(query_id, session)
Expand Down

0 comments on commit ab419a1

Please sign in to comment.