From 8b4cf87368238d199e36ebab12e3595bf6e3debe Mon Sep 17 00:00:00 2001
From: Roberto Rosario <roberto.rosario.gonzalez@gmail.com>
Date: Fri, 3 Aug 2012 06:19:17 -0400
Subject: [PATCH] Tweak db connection closing to ensure a fresh connection to
 high frequency called code

---
 apps/job_processor/models.py | 4 ++--
 apps/lock_manager/models.py  | 1 +
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/apps/job_processor/models.py b/apps/job_processor/models.py
index dd68da8b63..b9a5b0acb8 100644
--- a/apps/job_processor/models.py
+++ b/apps/job_processor/models.py
@@ -33,6 +33,7 @@ job_types_registry = {}
 
 class Job(object):
     def __init__(self, function, job_queue_item):
+        close_connection()
         # Run sync or launch async subprocess
         # OR launch 2 processes: monitor & actual process
         node = Node.objects.myself()
@@ -51,8 +52,7 @@ class Job(object):
             job_queue_item.delete()
         finally:
             worker.delete()
-            close_connection()
-
+            
 
 class JobType(object):
     def __init__(self, name, label, function):
diff --git a/apps/lock_manager/models.py b/apps/lock_manager/models.py
index 62e8fd048d..d4cd91abee 100644
--- a/apps/lock_manager/models.py
+++ b/apps/lock_manager/models.py
@@ -30,6 +30,7 @@ class Lock(models.Model):
     @transaction.commit_on_success
     def release(self):
         try:
+            close_connection()
             lock = Lock.objects.get(name=self.name, creation_datetime=self.creation_datetime)
             lock.delete()
         except Lock.DoesNotExist: