Update/ben/snowflake app name

redash/handlers/query_results.py

@@ -119,9 +119,7 @@ def run_query(
             current_user.id,
             current_user.is_api_user(),
             metadata={
-                "Username": repr(current_user)
-                if current_user.is_api_user()
-                else current_user.email,
+                "Username": current_user.get_actual_user(),
                 "query_id": query_id,
             },
         )

redash/models/users.py

@@ -256,7 +256,8 @@ def get_id(self):
         ).hexdigest()
         return "{0}-{1}".format(self.id, identity)
 
-
+    def get_actual_user(self):
+        return repr(self) if self.is_api_user() else self.email
 @generic_repr("id", "name", "type", "org_id")
 class Group(db.Model, BelongsToOrgMixin):
     DEFAULT_PERMISSIONS = [

redash/query_runner/snowflake.py

@@ -5,6 +5,7 @@
 except ImportError:
     enabled = False
 
+from redash import __version__
 from redash.query_runner import BaseQueryRunner, register
 from redash.query_runner import (
     TYPE_STRING,
@@ -100,6 +101,7 @@ def _get_connection(self):
             account=account,
             region=region,
             host=host,
+            application="Redash/{} (Snowflake)".format(__version__.split("-")[0]),
         )
 
         return connection

redash/tasks/queries/maintenance.py

@@ -98,7 +98,7 @@ def refresh_queries():
                 query.data_source,
                 query.user_id,
                 scheduled_query=query,
-                metadata={"query_id": query.id, "Username": "Scheduled"},
+                metadata={"query_id": query.id, "Username": query.user.get_actual_user()},
             )
             enqueued.append(query)
         except Exception as e:

tests/tasks/test_refresh_queries.py

@@ -31,14 +31,14 @@ def test_enqueues_outdated_queries_for_sqlquery(self):
                         query1.data_source,
                         query1.user_id,
                         scheduled_query=query1,
-                        metadata={"query_id": query1.id, "Username": "Scheduled"},
+                        metadata={"query_id": query1.id, "Username": query1.user.get_actual_user()},
                     ),
                     call(
                         "select 42 LIMIT 1000",
                         query2.data_source,
                         query2.user_id,
                         scheduled_query=query2,
-                        metadata={"query_id": query2.id, "Username": "Scheduled"},
+                        metadata={"query_id": query2.id, "Username": query2.user.get_actual_user()},
                     ),
                 ],
                 any_order=True,
@@ -71,14 +71,14 @@ def test_enqueues_outdated_queries_for_non_sqlquery(self):
                         query1.data_source,
                         query1.user_id,
                         scheduled_query=query1,
-                        metadata={"query_id": query1.id, "Username": "Scheduled"},
+                        metadata={"query_id": query1.id, "Username": query1.user.get_actual_user()},
                     ),
                     call(
                         query2.query_text,
                         query2.data_source,
                         query2.user_id,
                         scheduled_query=query2,
-                        metadata={"query_id": query2.id, "Username": "Scheduled"},
+                        metadata={"query_id": query2.id, "Username": query2.user.get_actual_user()},
                     ),
                 ],
                 any_order=True,