1 files changed, 0 insertions, 92 deletions
diff --git a/src/etcd/tests/integration/test_lock.py b/src/etcd/tests/integration/test_lock.py
deleted file mode 100644
index a5d8744..0000000
--- a/src/etcd/tests/integration/test_lock.py
+++ /dev/null
@@ -1,92 +0,0 @@
-import etcd
-from . import test_simple
-import time
-
-class TestLocks(test_simple.EtcdIntegrationTest):
-    def setUp(self):
-        self.client = etcd.Client(port=6001)
-
-    def test_acquire_lock(self):
-        """ Can acquire a lock. """
-        key = '/testkey'
-        ttl = 1
-        expected_index = '2'
-        lock = self.client.get_lock(key, ttl=ttl).acquire()
-        self.assertEquals(lock._index, expected_index)
-        lock.release()
-        self.assertEquals(lock._index, None)
-
-    def test_acquire_lock_invalid_ttl(self):
-        """ Invalid TTL throws an error """
-        key = '/testkey'
-        ttl = 'invalid'
-        expected_index = 'invalid'
-        lock = self.client.get_lock(key, ttl=ttl)
-        self.assertRaises(ValueError, lock.acquire)
-
-    def test_acquire_lock_with_context_manager(self):
-        key = '/testkey'
-        ttl = 1
-        lock = self.client.get_lock(key, ttl=ttl)
-        with lock:
-            self.assertTrue(lock.is_locked())
-        self.assertFalse(lock.is_locked())
-
-    def test_is_locked(self):
-        key = '/testkey'
-        ttl = 1
-        lock = self.client.get_lock(key, ttl=ttl)
-        self.assertFalse(lock.is_locked())
-        lock.acquire()
-        self.assertTrue(lock.is_locked())
-        lock.release()
-
-    def test_is_locked_on_expired_key(self):
-        key = '/testkey'
-        ttl = 1
-        lock = self.client.get_lock(key, value='test', ttl=ttl).acquire()
-        time.sleep(3)
-        self.assertFalse(lock.is_locked())
-
-    def test_renew(self):
-        key = '/testkey'
-        ttl = 1
-        lock = self.client.get_lock(key, ttl=ttl)
-        lock.acquire()
-        self.assertTrue(lock.is_locked())
-        lock.renew(2)
-        # TODO sleep(1)?
-        self.assertTrue(lock.is_locked())
-        lock.release()
-
-    def test_renew_fails_without_locking(self):
-        key = '/testkey'
-        ttl = 1
-        lock = self.client.get_lock(key, ttl=ttl)
-        self.assertEquals(lock._index, None)
-        self.assertRaises(etcd.EtcdException, lock.renew, 2)
-
-    def test_release(self):
-        key = '/testkey'
-        ttl = 1
-        index = '2'
-        lock = self.client.get_lock(key, ttl=ttl)
-        lock.acquire()
-        self.assertTrue(lock.is_locked())
-        lock.release()
-        self.assertFalse(lock.is_locked())
-
-    def test_release_fails_without_locking(self):
-        key = '/testkey'
-        ttl = 1
-        lock = self.client.get_lock(key, ttl=ttl)
-        self.assertEquals(lock._index, None)
-        self.assertRaises(etcd.EtcdException, lock.release)
-
-    def test_get(self):
-        key = '/testkey'
-        ttl = 5
-        with self.client.get_lock(key, ttl=ttl) as lock:
-            lock2 = self.client.get_lock(key).get()
-            self.assertTrue(lock2.is_locked())
-        self.assertFalse(lock2.is_locked())