diff options
author | Craig Hawco <craig.hawco@gmail.com> | 2010-09-03 13:22:52 -0400 |
---|---|---|
committer | Craig Hawco <craig.hawco@gmail.com> | 2010-09-03 13:22:52 -0400 |
commit | e24ae566d57351e688c185f402d4a26d349d3ee2 (patch) | |
tree | afb3f63ce1c721c0a51aacd8c0fd61b3cac69bff | |
parent | ec71ea0508a4f9c34a31a728008ae6a4adbc706c (diff) | |
download | redis-py-e24ae566d57351e688c185f402d4a26d349d3ee2.tar.gz |
Add some tests for WATCH
-rw-r--r-- | tests/server_commands.py | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/tests/server_commands.py b/tests/server_commands.py index efcf2d6..3d4b3aa 100644 --- a/tests/server_commands.py +++ b/tests/server_commands.py @@ -213,6 +213,25 @@ class ServerCommandsTestCase(unittest.TestCase): self.client.zadd('a', '1', 1) self.assertEquals(self.client.type('a'), 'zset') + def test_watch(self): + self.client.set("a", 1) + + self.client.watch("a") + pipeline = self.client.pipeline() + pipeline.set("a", 2) + self.assertEquals(pipeline.execute(), [True]) + + self.client.set("b", 1) + self.client.watch("b") + self.get_client().set("b", 2) + pipeline = self.client.pipeline() + pipeline.set("b", 3) + + self.assertRaises(redis.exceptions.WatchError, pipeline.execute) + + def test_unwatch(self): + self.assertEquals(self.client.unwatch(), True) + # LISTS def make_list(self, name, l): for i in l: |