import ceph quincy 17.2.6

[ceph.git] / ceph / src / test / pybind / test_rados.py

diff --git a/ceph/src/test/pybind/test_rados.py b/ceph/src/test/pybind/test_rados.py
index 508cbe5ae9e469056a2ed3dd6a59778d746b6cb8..ff6fee3db29633d1059cb0931d72a4f0ac9d5287 100644 (file)
--- a/ceph/src/test/pybind/test_rados.py
+++ b/ceph/src/test/pybind/test_rados.py
@@ -1373,6 +1373,7 @@ class TestCommand(object):
         eq(u"pool '\u9ec5' created", out)
 
 
+@attr('watch')
 class TestWatchNotify(object):
     OID = "test_watch_notify"
 
@@ -1401,8 +1402,9 @@ class TestWatchNotify(object):
         def callback(notify_id, notifier_id, watch_id, data):
             with self.lock:
                 if watch_id not in self.notify_cnt:
-                    self.notify_cnt[watch_id] = 0
-                self.notify_cnt[watch_id] += 1
+                    self.notify_cnt[watch_id] = 1
+                elif  self.notify_data[watch_id] != data:
+                    self.notify_cnt[watch_id] += 1
                 self.notify_data[watch_id] = data
         return callback