IVS-750 report workflow failure reason

backend/apps/ifc_validation/tasks/task_runner.py

@@ -156,8 +156,19 @@ def on_workflow_failed(self, *args, **kwargs):
 
     # update status
     id = args[1]
-    reason = f"Processing failed: args={args} kwargs={kwargs}"
     request = ValidationRequest.objects.get(pk=id)
+
+    # Both error callbacks can fire for one failure; skip if already finalized so the
+    # failure emails aren't sent twice.
+    if request.status == ValidationRequest.Status.FAILED:
+        logger.debug(f"Request {id} already marked FAILED; skipping duplicate failure handling.")
+        return
+
+    # Record a readable reason rather than the raw celery args/kwargs (full detail is logged above).
+    exc = next((a for a in args if isinstance(a, BaseException)), None)
+    reason = "Validation failed before any check could run (workflow-level error)."
+    if exc:
+        reason += f" Error: {exc}"
     request.mark_as_failed(reason)
 
     # queue sending email

backend/apps/ifc_validation/tests/tests_orphan_failed_request.py

@@ -0,0 +1,128 @@
+"""
+Workflow-level failure handling in on_workflow_failed.
+
+Fixes two defects without fabricating a synthetic task:
+  1. it could fire twice (link_error + chord on_error), double-sending failure
+     emails -> idempotency guard;
+  2. it dumped raw celery args/kwargs into status_reason -> readable reason instead.
+
+The failed request keeps zero tasks by design: the failure is explained on the
+request itself rather than by inventing a task that never ran.
+"""
+
+from unittest.mock import patch
+
+from django.test import TestCase
+from django.contrib.auth.models import User
+
+from apps.ifc_validation_models.models import (
+    set_user_context,
+    ValidationRequest,
+    ValidationTask,
+)
+
+from apps.ifc_validation.tasks.task_runner import (
+    on_workflow_failed,
+    on_workflow_completed,
+)
+
+
+class OrphanFailedRequestElegantTestCase(TestCase):
+
+    @staticmethod
+    def _set_user_context():
+        user, _ = User.objects.get_or_create(
+            id=1, defaults={'username': 'SYSTEM', 'is_active': True},
+        )
+        set_user_context(user)
+        return user
+
+    def _make_request(self):
+        user = self._set_user_context()
+        request = ValidationRequest.objects.create(
+            file_name='orphan_file.ifc', file='orphan_file.ifc', size=123,
+        )
+        request.mark_as_initiated()
+        if request.created_by_id is None:
+            request.created_by = user
+            request.save()
+        return request
+
+    # --- the failure is now FAILED with a clean reason, and no raw arg dump ---
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_admin_email_task')
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_email_task')
+    def test_orphan_failure_sets_clean_reason(self, mock_user_email, mock_admin_email):
+        request = self._make_request()
+
+        result = on_workflow_failed.apply(args=[None, request.id], kwargs={})
+        if result.failed():
+            self.fail(f"on_workflow_failed raised: {result.traceback}")
+
+        request.refresh_from_db()
+
+        self.assertEqual(request.status, ValidationRequest.Status.FAILED)
+        self.assertTrue(
+            request.status_reason.startswith("Validation failed before any check could run"),
+            f"reason should be human-readable, got: {request.status_reason!r}",
+        )
+        # No raw celery dump leaked into the user-visible reason.
+        self.assertNotIn("args=", request.status_reason)
+        self.assertNotIn("kwargs=", request.status_reason)
+        # Option B intentionally does NOT create a synthetic task.
+        self.assertEqual(request.tasks.count(), 0)
+        mock_user_email.delay.assert_called_once()
+        mock_admin_email.delay.assert_called_once()
+
+    # --- firing twice no longer double-sends emails ---
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_admin_email_task')
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_email_task')
+    def test_double_fire_is_idempotent(self, mock_user_email, mock_admin_email):
+        request = self._make_request()
+
+        first = on_workflow_failed.apply(args=[None, request.id], kwargs={})
+        second = on_workflow_failed.apply(args=[None, request.id], kwargs={})
+        for r in (first, second):
+            if r.failed():
+                self.fail(f"on_workflow_failed raised: {r.traceback}")
+
+        request.refresh_from_db()
+        self.assertEqual(request.status, ValidationRequest.Status.FAILED)
+        self.assertEqual(mock_user_email.delay.call_count, 1,
+                         "failure email must be sent exactly once across both firings")
+        self.assertEqual(mock_admin_email.delay.call_count, 1,
+                         "admin failure email must be sent exactly once across both firings")
+
+    # --- when an exception is available it is surfaced in the reason ---
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_admin_email_task')
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_email_task')
+    def test_reason_includes_exception_when_present(self, mock_user_email, mock_admin_email):
+        request = self._make_request()
+
+        # error callbacks may carry the original exception; id is still args[1].
+        result = on_workflow_failed.apply(args=[ValueError("boom in syntax"), request.id], kwargs={})
+        if result.failed():
+            self.fail(f"on_workflow_failed raised: {result.traceback}")
+
+        request.refresh_from_db()
+        self.assertIn("boom in syntax", request.status_reason)
+
+    # --- regression: the in-workflow failure path still has its relating task ---
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_admin_email_task')
+    @patch('apps.ifc_validation.tasks.task_runner.send_failure_email_task')
+    def test_completed_failure_path_has_relating_task(self, mock_user_email, mock_admin_email):
+        request = self._make_request()
+        ValidationTask.objects.create(
+            request=request,
+            type=ValidationTask.Type.SYNTAX,
+            status=ValidationTask.Status.FAILED,
+        )
+
+        result = on_workflow_completed.apply(args=[None], kwargs={'id': request.id})
+        if result.failed():
+            self.fail(f"on_workflow_completed raised: {result.traceback}")
+
+        request.refresh_from_db()
+        self.assertEqual(request.status, ValidationRequest.Status.FAILED)
+        self.assertEqual(request.tasks.count(), 1)
+        mock_user_email.delay.assert_called_once()
+        mock_admin_email.delay.assert_called_once()