Merge pull request #346 from globocom/develop

Develop to master

networkapi/distributedlock/__init__.py

@@ -117,3 +117,6 @@ def __enter__(self):
     def __exit__(self, type, value, traceback):
         _debug('releasing lock %s' % self.key)
         self.lock.release()
+
+    def get_cached_data(self):
+        return self.lock.get_cached_data()

networkapi/distributedlock/memcachedlock.py

@@ -69,3 +69,8 @@ def release(self):
         else:
             log.warning(
                 "I've no lock to release. Increase TIMEOUT of lock operations")
+
+    def get_cached_data(self):
+        value = self.client.get(self.key)
+
+        return value if value else None

networkapi/util/geral.py

@@ -72,6 +72,13 @@ def create_lock_with_blocking(locks_name):
     for lock_name in locks_name:
         try:
             lock = distributedlock(lock_name, blocking=False)
+            # TODO: This is a temporary solution for a high needed change. In the future we need to validate
+            #  why destroy_lock in models/create_v3 didn't work some times
+
+            if lock.get_cached_data():
+                log.info('Get cached lock data for {}. Disabling it and creating a new lock'.format(lock_name))
+                lock.lock.instance_id = lock.get_cached_data()
+                lock.__exit__('', '', '')
             lock.__enter__()
             locks_list.append(lock)
         except LockNotAcquiredError: