feat: use new fields

Author: ablaszkiewicz

posthog/hogql/database/database.py

@@ -1433,11 +1433,17 @@ def _use_error_tracking_issue_id_from_error_tracking_issue_overrides(database: D
     )
     table.fields["assigned_user_id"] = ExpressionField(
         name="assigned_user_id",
-        expr=parse_expr("exception_issue_denormalized.assigned_user_id"),
+        expr=parse_expr(
+            "if(equals(toString(exception_issue_denormalized.assigned_entity_type), 'user'), toInt64OrNull(exception_issue_denormalized.assigned_entity_id), NULL)",
+            start=None,
+        ),
     )
     table.fields["assigned_role_id"] = ExpressionField(
         name="assigned_role_id",
-        expr=parse_expr("exception_issue_denormalized.assigned_role_id"),
+        expr=parse_expr(
+            "if(equals(toString(exception_issue_denormalized.assigned_entity_type), 'role'), exception_issue_denormalized.assigned_entity_id, NULL)",
+            start=None,
+        ),
     )
     table.fields["issue_first_seen"] = ExpressionField(
         name="issue_first_seen",

posthog/hogql/database/schema/error_tracking_issue_fingerprint_denormalized.py

@@ -22,8 +22,8 @@
     "issue_name": StringDatabaseField(name="issue_name", nullable=True),
     "issue_description": StringDatabaseField(name="issue_description", nullable=True),
     "issue_status": StringDatabaseField(name="issue_status", nullable=False),
-    "assigned_user_id": IntegerDatabaseField(name="assigned_user_id", nullable=True),
-    "assigned_role_id": StringDatabaseField(name="assigned_role_id", nullable=True),
+    "assigned_entity_type": StringDatabaseField(name="assigned_entity_type", nullable=True),
+    "assigned_entity_id": StringDatabaseField(name="assigned_entity_id", nullable=True),
     "first_seen": DateTimeDatabaseField(name="first_seen", nullable=True),
 }
 

products/error_tracking/backend/models.py

@@ -543,6 +543,16 @@ def sync_issue_to_clickhouse(issue_id: UUID, team_id: int) -> None:
     p = ClickhouseProducer()
 
     for fingerprint, first_seen in fingerprint_records:
+        assigned_entity_type = None
+        assigned_entity_id = None
+        if assignment:
+            if assignment.user_id:
+                assigned_entity_type = "user"
+                assigned_entity_id = str(assignment.user_id)
+            elif assignment.role_id:
+                assigned_entity_type = "role"
+                assigned_entity_id = str(assignment.role_id)
+
         p.produce(
             topic=KAFKA_ERROR_TRACKING_ISSUE_FINGERPRINT_DENORMALIZED,
             sql=INSERT_ERROR_TRACKING_ISSUE_FINGERPRINT_DENORMALIZED,
@@ -553,8 +563,8 @@ def sync_issue_to_clickhouse(issue_id: UUID, team_id: int) -> None:
                 "issue_name": issue.name,
                 "issue_description": issue.description,
                 "issue_status": issue.status,
-                "assigned_user_id": assignment.user_id if assignment else None,
-                "assigned_role_id": str(assignment.role_id) if assignment and assignment.role_id else None,
+                "assigned_entity_type": assigned_entity_type,
+                "assigned_entity_id": assigned_entity_id,
                 "first_seen": first_seen.strftime("%Y-%m-%d %H:%M:%S.%f") if first_seen else "1970-01-01 00:00:00.000",
                 "is_deleted": 0,
                 "version": version,