import 15.2.5

[ceph.git] / ceph / src / pybind / mgr / pg_autoscaler / module.py

diff --git a/ceph/src/pybind/mgr/pg_autoscaler/module.py b/ceph/src/pybind/mgr/pg_autoscaler/module.py
index f9242f59b5717e06f849934e5e03a55ffab35446..64e2a7465831aca9c68579b4592838ff1ee4c5f1 100644 (file)
--- a/ceph/src/pybind/mgr/pg_autoscaler/module.py
+++ b/ceph/src/pybind/mgr/pg_autoscaler/module.py
@@ -407,7 +407,7 @@ class PgAutoscaler(MgrModule):
         for pool_id in list(self._event):
             ev = self._event[pool_id]
             pool_data = pools.get(pool_id)
-            if pool_data is None or pool_data['pg_num'] == pool_data['pg_num_target']:
+            if pool_data is None or pool_data['pg_num'] == pool_data['pg_num_target'] or ev.pg_num == ev.pg_num_target:
                 # pool is gone or we've reached our target
                 self.remote('progress', 'complete', ev.ev_id)
                 del self._event[pool_id]