feat(models): Add exception name into task.error attribute

Author: malvex

examples/testing/test_assert_helper_functions.py

@@ -36,4 +36,4 @@ def test_fail_once():
 
     # check results manually as well
     assert processed[0].result == 3
-    assert processed[1].error == "division by zero"
+    assert processed[1].error == "ZeroDivisionError: division by zero"

examples/testing/test_failure.py

@@ -26,4 +26,4 @@ def test_divide_by_zero():
 
     # verify the second task result (should fail)
     assert processed_tasks[1].completed is False
-    assert processed_tasks[1].error == "division by zero"
+    assert processed_tasks[1].error == "ZeroDivisionError: division by zero"

examples/testing/test_retry_logic.py

@@ -31,7 +31,7 @@ def test_fail_once():
 
     # verify the task result
     assert processed[0].completed is False
-    assert processed[0].error == "task failed"
+    assert processed[0].error == "ValueError: task failed"
 
     # retry should succeed
     assert processed[1].completed is True

src/sheppy/testqueue.py

@@ -86,7 +86,7 @@ def test_failing_task():
             # check task is failed
             assert_is_failed(processed_task)
             assert processed_task.result is None
-            assert processed_task.error == "division by zero"
+            assert processed_task.error == "ZeroDivisionError: division by zero"
 
             # check queue size is now zero
             assert q.size() == 0

src/sheppy/utils/task_execution.py

@@ -123,7 +123,7 @@ def handle_success_and_update_task_metadata(task: TaskInternal, result: Any, wor
     @staticmethod
     async def handle_failed_task(task: TaskInternal, exception: Exception) -> TaskInternal:
         task.completed = False
-        task.error = str(exception)
+        task.error = f"{exception.__class__.__name__}: {exception}"
 
         if task.is_retriable:
             task = TaskProcessor.handle_retry(task)

tests/contract/test_backend.py

@@ -30,13 +30,13 @@ def _set_completed(task: TaskInternal) -> None:
 
     def _set_failed(task: TaskInternal) -> None:
         task.completed = False
-        task.error = "some error happened"
+        task.error = "Exception: some error happened"
         task.result = None
         task.finished_at = datetime_now
 
     def _set_failed_should_retry(task: TaskInternal) -> None:
         task.completed = False
-        task.error = "some error happened"
+        task.error = "Exception: some error happened"
         task.result = None
         task.retry_count += 1
         task.last_retry_at = datetime_now - timedelta(seconds=6)

tests/contract/test_retry.py

@@ -17,7 +17,7 @@ async def test_retry(task_fail_once_fn: Callable[[], Task], queue: Queue, worker
 
     t = await queue.get_task(t)
     assert_is_failed(t)
-    assert t.error == "transient error"
+    assert t.error == "Exception: transient error"
     assert t.retry_count == 1
 
     await worker.work(1)

tests/dependencies.py

@@ -496,14 +496,14 @@ def failing_tasks() -> list[TaskTestCase]:
                 failing_task,
                 kwargs={"message": "Test failure"},
                 should_fail=True,
-                expected_error="Test failure"
+                expected_error="ValueError: Test failure"
             ),
             TaskTestCase(
                 "async_failure",
                 async_failing_task,
                 kwargs={"message": "Async test failure"},
                 should_fail=True,
-                expected_error="Async test failure"
+                expected_error="ValueError: Async test failure"
             ),
         ]