From 1b333777116a47e47025ded473cb30410600cdd5 Mon Sep 17 00:00:00 2001 From: Ahmad Bilal Khalid Date: Wed, 3 Jul 2019 17:53:22 +0500 Subject: [PATCH] watch_prefix method skips event if its value is None --- .gitignore | 1 + etcd_wrapper.py | 6 +++++- 2 files changed, 6 insertions(+), 1 deletion(-) create mode 100644 .gitignore diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..bee8a64 --- /dev/null +++ b/.gitignore @@ -0,0 +1 @@ +__pycache__ diff --git a/etcd_wrapper.py b/etcd_wrapper.py index 4620e84..7c86771 100644 --- a/etcd_wrapper.py +++ b/etcd_wrapper.py @@ -45,4 +45,8 @@ class Etcd3Wrapper(object): def watch_prefix(self, *args, value_in_json=False, **kwargs): r, _ = self.client.watch_prefix(*args, **kwargs) for event in r: - yield EtcdEntry(event, event.value, value_in_json=value_in_json) + # if e.value is None don't propagate its value + if event.value is None: + continue + event = EtcdEntry(event, event.value, value_in_json=value_in_json) + yield event \ No newline at end of file