diff --git a/ceilometer/polling/manager.py b/ceilometer/polling/manager.py index adf1f67dcd..2b9e5a0d19 100644 --- a/ceilometer/polling/manager.py +++ b/ceilometer/polling/manager.py @@ -384,7 +384,7 @@ class AgentManager(cotyledon.Service): super(AgentManager, self).run() self.polling_manager = PollingManager(self.conf) if self.partition_coordinator: - self.partition_coordinator.start() + self.partition_coordinator.start(start_heart=True) self.join_partitioning_groups() self.start_polling_tasks() @@ -400,6 +400,11 @@ class AgentManager(cotyledon.Service): self._keystone = None self._keystone_last_exception = None + # Note(leehom): if coordinator enabled call run_watchers to + # update group member info before collecting + if self.partition_coordinator: + self.partition_coordinator.run_watchers() + task.poll_and_notify() @property