Remove transaction wrapping tasks which prevents transactions from be…

…ing used within the task
neuronostics · Dec 13, 2023 · 780ac3a · 780ac3a
1 parent 575279e
commit 780ac3a
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/pgq/decorators.py b/pgq/decorators.py
@@ -84,10 +84,9 @@ 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: