fix(error-tracking): query issues by severity

frontend/src/queries/schema/schema-general.ts

@@ -3769,13 +3769,17 @@ export type CachedSessionAttributionExplorerQueryResponse = CachedQueryResponse<
 /** @title ErrorTrackingOrderBy */
 export type ErrorTrackingOrderBy = 'last_seen' | 'first_seen' | 'occurrences' | 'users' | 'sessions'
 
+/** @title ErrorTrackingQueryIssueSeverity */
+export type ErrorTrackingQueryIssueSeverity = 'low' | 'medium' | 'high' | 'critical'
+
 /** Client-side pending fingerprint issue state update UNIONed into the argMax subquery to hide Kafka->CH sync lag after mutations. This has to be kept in sync with the CH schema */
 export interface ErrorTrackingPendingFingerprintIssueStateUpdate {
     fingerprint: string
     issue_id: string
     issue_name: string | null
     issue_description: string | null
     issue_status: string
+    issue_severity: ErrorTrackingQueryIssueSeverity | null
     assigned_user_id: integer | null
     assigned_role_id: string | null
     /** ISO 8601 datetime string. */
@@ -3929,6 +3933,7 @@ export interface ErrorTrackingRelationalIssue {
     description: string | null
     assignee: ErrorTrackingIssueAssignee | null
     status: ErrorTrackingIssueStatus
+    severity?: ErrorTrackingQueryIssueSeverity | null
     /**  @format date-time */
     first_seen: string
     external_issues?: ErrorTrackingExternalReference[]

posthog/hogql/database/database.py

@@ -2425,6 +2425,7 @@ def _error_tracking_event_exprs() -> dict[str, ast.Expr]:
         "issue_name": parse_expr("fingerprint_issue_state.issue_name", start=None),
         "issue_description": parse_expr("fingerprint_issue_state.issue_description", start=None),
         "issue_status": parse_expr("fingerprint_issue_state.issue_status", start=None),
+        "issue_severity": parse_expr("fingerprint_issue_state.issue_severity", start=None),
         "issue_assigned_user_id": parse_expr("fingerprint_issue_state.assigned_user_id", start=None),
         "issue_assigned_role_id": parse_expr("fingerprint_issue_state.assigned_role_id", start=None),
         "issue_first_seen": parse_expr("fingerprint_issue_state.first_seen", start=None),
@@ -2453,6 +2454,7 @@ def _add_error_tracking_fields(database: Database) -> None:
     table.fields["issue_name"] = ExpressionField(name="issue_name", expr=exprs["issue_name"])
     table.fields["issue_description"] = ExpressionField(name="issue_description", expr=exprs["issue_description"])
     table.fields["issue_status"] = ExpressionField(name="issue_status", expr=exprs["issue_status"])
+    table.fields["issue_severity"] = ExpressionField(name="issue_severity", expr=exprs["issue_severity"], hidden=True)
     table.fields["issue_assigned_user_id"] = ExpressionField(
         name="issue_assigned_user_id", expr=exprs["issue_assigned_user_id"]
     )

posthog/hogql/database/schema/error_tracking_fingerprint_issue_state.py

@@ -41,6 +41,12 @@
     "issue_status": StringDatabaseField(
         name="issue_status", nullable=True, description="Current status of the issue, e.g. 'active', 'resolved'."
     ),
+    "issue_severity": StringDatabaseField(
+        name="issue_severity",
+        nullable=True,
+        hidden=True,
+        description="Assigned issue severity, or null when unassigned.",
+    ),
     "assigned_user_id": IntegerDatabaseField(
         name="assigned_user_id", nullable=True, description="User the issue is assigned to, if any."
     ),
@@ -60,6 +66,7 @@
     "issue_name",
     "issue_description",
     "issue_status",
+    "issue_severity",
     "assigned_user_id",
     "assigned_role_id",
     "first_seen",
@@ -106,6 +113,7 @@ def join_with_error_tracking_fingerprint_issue_state_table(
     "issue_name",
     "issue_description",
     "issue_status",
+    "issue_severity",
     "assigned_user_id",
     "assigned_role_id",
     "first_seen",
@@ -226,6 +234,7 @@ def _pending_update_select(row: dict[str, Any]):
         "issue_name": ast.Constant(value=row.get("issue_name")),
         "issue_description": ast.Constant(value=row.get("issue_description")),
         "issue_status": ast.Constant(value=str(row["issue_status"])),
+        "issue_severity": ast.Constant(value=row.get("issue_severity")),
         "assigned_user_id": ast.Call(name="_toInt64", args=[ast.Constant(value=int(assigned_user_id))])
         if assigned_user_id is not None
         else ast.Constant(value=None),

posthog/hogql/database/test/__snapshots__/test_database.ambr

@@ -1316,6 +1316,7 @@
                       "issue_name",
                       "issue_description",
                       "issue_status",
+                      "issue_severity",
                       "assigned_user_id",
                       "assigned_role_id",
                       "first_seen",
@@ -12129,6 +12130,7 @@
                       "issue_name",
                       "issue_description",
                       "issue_status",
+                      "issue_severity",
                       "assigned_user_id",
                       "assigned_role_id",
                       "first_seen",