fix test

only fetch project if necessary

Author: wedamija

src/sentry/issues/occurrence_consumer.py

@@ -144,15 +144,15 @@ def _get_kwargs(payload: Mapping[str, Any]) -> Mapping[str, Any]:
         with metrics.timer("occurrence_ingest.duration", instance="_get_kwargs"):
             metrics.distribution("occurrence.ingest.size.data", len(payload), unit="byte")
             assignee_identifier = None
-            project = Project.objects.get_from_cache(id=payload["project_id"])
-            try:
-                assignee = parse_and_validate_actor(
-                    payload.get("assignee"), project.organization_id
-                )
-                if assignee:
-                    assignee_identifier = assignee.identifier
-            except Exception:
-                logger.exception("Failed to validate assignee for occurrence")
+            payload_assignee = payload.get("assignee")
+            if payload_assignee:
+                project = Project.objects.get_from_cache(id=payload["project_id"])
+                try:
+                    assignee = parse_and_validate_actor(payload_assignee, project.organization_id)
+                    if assignee:
+                        assignee_identifier = assignee.identifier
+                except Exception:
+                    logger.exception("Failed to validate assignee for occurrence")
 
             occurrence_data = {
                 "id": UUID(payload["id"]).hex,

tests/sentry/issues/test_occurrence_consumer.py

@@ -387,8 +387,8 @@ def test_missing_event_id_in_event_data(self) -> None:
 
     def test_project_ids_mismatch(self) -> None:
         message = deepcopy(get_test_message(self.project.id))
-        message["project_id"] = 1
-        message["event"]["project_id"] = 2
+        message["project_id"] = self.project.id
+        message["event"]["project_id"] = 999999999999
         with pytest.raises(InvalidEventPayloadError):
             _get_kwargs(message)