This is an automated email from the ASF dual-hosted git repository. robdiciuccio pushed a commit to branch rd/aq-after-request-debug in repository https://gitbox.apache.org/repos/asf/superset.git
commit 6eb52685d0fb216a289dd139ecbca3f1e5bd02ac Author: Rob DiCiuccio <[email protected]> AuthorDate: Fri Aug 27 14:07:20 2021 -0700 Add debugging for after_request hook --- superset/utils/async_query_manager.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/superset/utils/async_query_manager.py b/superset/utils/async_query_manager.py index 14f89a8..c0eab35 100644 --- a/superset/utils/async_query_manager.py +++ b/superset/utils/async_query_manager.py @@ -113,6 +113,10 @@ class AsyncQueryManager: @app.after_request def validate_session(response: Response) -> Response: + logger.info('#### validate_session') + logger.info(session) + logger.info(g.user) + user_id = None try: @@ -121,6 +125,8 @@ class AsyncQueryManager: except Exception: # pylint: disable=broad-except pass + logger.info(f'#### user_id {user_id}') + reset_token = ( not request.cookies.get(self._jwt_cookie_name) or "async_channel_id" not in session @@ -128,6 +134,8 @@ class AsyncQueryManager: or user_id != session["async_user_id"] ) + logger.info(f'#### reset_token {reset_token}') + if reset_token: async_channel_id = str(uuid.uuid4()) session["async_channel_id"] = async_channel_id @@ -136,6 +144,8 @@ class AsyncQueryManager: sub = str(user_id) if user_id else None token = self.generate_jwt({"channel": async_channel_id, "sub": sub}) + logger.info(f'#### cookie: {token}, {self._jwt_cookie_name}, {self._jwt_cookie_domain}') + response.set_cookie( self._jwt_cookie_name, value=token,
