diff --git a/redash/query_runner/trino.py b/redash/query_runner/trino.py index faba4819de..1a62d79bd8 100644 --- a/redash/query_runner/trino.py +++ b/redash/query_runner/trino.py @@ -112,7 +112,10 @@ def run_query(self, query, user): host=self.configuration.get("host", ""), port=self.configuration.get("port", 8080), catalog=self.configuration.get("catalog", "hive"), - http_headers={trino.constants.HEADER_CLIENT_INFO: str(user)}, + http_headers={ + trino.constants.HEADER_CLIENT_INFO: str(user), + "X-Trino-Original-User": str(user) + }, source="Redash", schema=self.configuration.get("schema", "default"), user=self.configuration.get("username"),