summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorarushiagg <arushi987@gmail.com>2018-02-26 14:20:00 -0800
committerJeff Widman <jeff@jeffwidman.com>2018-02-26 14:20:00 -0800
commit2385079267db0bea6793c4f20588644381803a98 (patch)
treefa1ec87e60ed701bb416c0ffe1fab6919b0bc430
parent4d268adf9837836f05dde5ec81be0d7bbd759e78 (diff)
downloadkazoo-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.py7
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