Fix: handling exceptions inside job function (#51)

django_q/cluster.py

@@ -485,19 +485,12 @@ def worker(
         try:
             res = f(*task["args"], **task["kwargs"])
             result = (res, True)
-        except Exception:
+        except Exception as e:
-            result = (
+            result = (f"{e} : {traceback.format_exc()}", False)
-                _(
-                    "Could not process '%(func_name)s'. Check the location of the "
-                    "function and the args/kwargs."
-                )
-                % {"func_name": func_name},
-                False,
-            )
             if error_reporter:
                 error_reporter.report()
             if task.get("sync", False):
-                raise Exception(result)
+                raise
         with timer.get_lock():
             # Process result
             task["result"] = result[0]

django_q/tests/test_cluster.py

@@ -29,7 +29,7 @@ from django_q.tasks import (
     result,
     result_group,
 )
-from django_q.tests.tasks import multiply
+from django_q.tests.tasks import multiply, TaskError
 from django_q.utils import add_months, add_years
 
 myPath = os.path.dirname(os.path.abspath(__file__))
@@ -64,7 +64,7 @@ def test_sync(broker):
 
 @pytest.mark.django_db
 def test_sync_raise_exception(broker):
-    with pytest.raises(Exception):
+    with pytest.raises(TaskError):
         async_task("django_q.tests.tasks.raise_exception", broker=broker, sync=True)