diff options
author | arushiagg <arushi987@gmail.com> | 2018-02-26 14:20:00 -0800 |
---|---|---|
committer | Jeff Widman <jeff@jeffwidman.com> | 2018-02-26 14:20:00 -0800 |
commit | 2385079267db0bea6793c4f20588644381803a98 (patch) | |
tree | fa1ec87e60ed701bb416c0ffe1fab6919b0bc430 | |
parent | 4d268adf9837836f05dde5ec81be0d7bbd759e78 (diff) | |
download | kazoo-2385079267db0bea6793c4f20588644381803a98.tar.gz |
fix: Pass watch as keyword arg instead of positional arg (#495)
We instrument calls to async functions, but are unable to get the watch parameter because it is not being passed as part of kwargs. This will allow us to capture the watch parameter.
-rw-r--r-- | kazoo/client.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/kazoo/client.py b/kazoo/client.py index 555fbd5..f583c06 100644 --- a/kazoo/client.py +++ b/kazoo/client.py @@ -997,7 +997,7 @@ class KazooClient(object): returns a non-zero error code. """ - return self.exists_async(path, watch).get() + return self.exists_async(path, watch=watch).get() def exists_async(self, path, watch=None): """Asynchronously check if a node exists. Takes the same @@ -1039,7 +1039,7 @@ class KazooClient(object): returns a non-zero error code """ - return self.get_async(path, watch).get() + return self.get_async(path, watch=watch).get() def get_async(self, path, watch=None): """Asynchronously get the value of a node. Takes the same @@ -1092,7 +1092,8 @@ class KazooClient(object): The `include_data` option. """ - return self.get_children_async(path, watch, include_data).get() + return self.get_children_async(path, watch=watch, + include_data=include_data).get() def get_children_async(self, path, watch=None, include_data=False): """Asynchronously get a list of child nodes of a path. Takes |