maxconcurrency refactor

Author: sylvinus

mrq/job.py

@@ -283,25 +283,29 @@ def perform(self):
 
         self.task.is_main_task = True
 
-        try:
-            lock = None
+        if not self.task.max_concurrency:
+
+            result = self.task.run_wrapped(self.data["params"])
 
-            if self.task.max_concurrency:
+        else:
 
-                if self.task.max_concurrency > 1:
-                    raise NotImplementedError()
+            if self.task.max_concurrency > 1:
+                raise NotImplementedError()
+
+            lock = None
+            try:
 
                 # TODO: implement a semaphore
                 lock = context.connections.redis.lock(self.redis_max_concurrency_key, timeout=self.timeout + 5)
                 if not lock.acquire(blocking=True, blocking_timeout=0):
                     raise MaxConcurrencyInterrupt()
 
-            result = self.task.run_wrapped(self.data["params"])
+                result = self.task.run_wrapped(self.data["params"])
 
-        finally:
-            if lock:
+            finally:
                 try:
-                    lock.release()
+                    if lock:
+                        lock.release()
                 except LockError:
                     pass