Fix to limit the number of check queue pressures.
@@ -147,6 +147,7 @@ class BaseScheduler(object):
_log.debug("_check_pressure %s" % self._pressure_event_actor_ids)
self.node.rm.check_pressure(self._pressure_event_actor_ids)
self._pressure_event_actor_ids = set([])
+ if not [True for t in self._tasks if t[1] == self._check_pressure]:
self.insert_task(self._check_pressure, 30)
#
