diff options
| author | Jean-Marc Saffroy <jean.marc.saffroy@scality.com> | 2018-07-17 20:20:50 +0200 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-10-08 14:01:00 -0700 |
| commit | 901cba7a40d67ec96c06abe109e3cf51a992b24d (patch) | |
| tree | 34329e20a8559049877667ccefba9b6e05ed2168 | |
| parent | 3033091530b8f0aba13a1b8d031a7297e54006c2 (diff) | |
| download | kazoo-901cba7a40d67ec96c06abe109e3cf51a992b24d.tar.gz | |
fix(core): get_children with include_data=True uses GetChildren2 types (#514)
| -rw-r--r-- | kazoo/protocol/connection.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kazoo/protocol/connection.py b/kazoo/protocol/connection.py index 7f686c0..27388e1 100644 --- a/kazoo/protocol/connection.py +++ b/kazoo/protocol/connection.py @@ -23,6 +23,7 @@ from kazoo.protocol.serialization import ( Connect, Exists, GetChildren, + GetChildren2, Ping, PingInstance, ReplyHeader, @@ -398,7 +399,7 @@ class ConnectionHandler(object): # Determine if watchers should be registered watcher = getattr(request, 'watcher', None) if not client._stopped.is_set() and watcher: - if isinstance(request, GetChildren): + if isinstance(request, (GetChildren, GetChildren2)): client._child_watchers[request.path].add(watcher) else: client._data_watchers[request.path].add(watcher) |