Fix: remove transaction wrap (#5)

* Remove transaction wrapping tasks which prevents transactions from being used within the task

* Remove test

* Fix formatting

* unused import

pgq/decorators.py

@@ -6,8 +6,6 @@
 from dataclasses import dataclass
 from typing import TYPE_CHECKING, Any, Callable, Dict, Optional, Type
 
-from django.db import transaction
-
 if TYPE_CHECKING:
     from .models import BaseJob
     from .queue import Queue
@@ -84,10 +82,7 @@ def inner(queue, job):
 
             try:
                 args = copy.deepcopy(job.args)
-                with transaction.atomic():
-                    result = fn(
-                        queue, job, args["func_args"], JobMetaType(**args["meta"])
-                    )
+                result = fn(queue, job, args["func_args"], JobMetaType(**args["meta"]))
             except Exc as e:
                 retries = job.args["meta"].get("retries", 0)
                 if retries < max_retries:

testproj/test_decorators.py

@@ -24,25 +24,3 @@ def demotask(queue: Queue, job: Job, args: Any, meta: JobMeta) -> int:
         demotask.enqueue({"count": 5})
         self.assertIn("demotask", queue.tasks)
         queue.run_once()
-
-    def test_atleastonce_retry_during_database_failure(self) -> None:
-        """
-        Force a database error in the task. Check that it was retried.
-        """
-
-        queue = AtLeastOnceQueue(tasks={})
-
-        @task(queue, max_retries=2)
-        def failuretask(queue: Queue, job: Job, args: Any, meta: JobMeta) -> None:
-            # group has max 150 chars for its name.
-            Group.objects.create(name="!" * 151)
-            return None
-
-        failuretask.enqueue({})
-        originaljob = Job.objects.all()[0]
-
-        queue.run_once()
-
-        retryjob = Job.objects.all()[0]
-        self.assertNotEqual(originaljob.id, retryjob.id)
-        self.assertEqual(retryjob.args["meta"]["retries"], 1)