diff options
| author | Julien Danjou <julien@danjou.info> | 2014-08-26 12:17:49 +0200 |
|---|---|---|
| committer | Nejc Saje <nsaje@redhat.com> | 2014-08-26 13:26:08 +0200 |
| commit | 9d7a153c9815385c3fd651fc3024825c6677fd10 (patch) | |
| tree | 2875094bcb3eb9166e192a96e3db4e69bc827411 | |
| parent | fe7af7b3c10bc60133a3fb8a9eade6f25da5f061 (diff) | |
| download | tooz-9d7a153c9815385c3fd651fc3024825c6677fd10.tar.gz | |
Fix zake driver with latest release
Change-Id: I58c7dfa2d61821c335846684f21f82a5e6dfd8e8
| -rw-r--r-- | tooz/drivers/zookeeper.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tooz/drivers/zookeeper.py b/tooz/drivers/zookeeper.py index 6ada6f7..1fdd8df 100644 --- a/tooz/drivers/zookeeper.py +++ b/tooz/drivers/zookeeper.py @@ -16,7 +16,6 @@ import collections import copy -import threading from kazoo import client from kazoo import exceptions @@ -358,7 +357,8 @@ class ZakeDriver(BaseZooKeeperDriver): without the need of real ZooKeeper servers. """ - fake_storage = zake.fake_storage.FakeStorage(threading.RLock()) + fake_storage = zake.fake_storage.FakeStorage( + zake.fake_client.k_threading.SequentialThreadingHandler()) def __init__(self, member_id, parsed_url, options): super(ZakeDriver, self).__init__(member_id, parsed_url, options) |