diff --git a/tendrl/node_agent/node_sync/__init__.py b/tendrl/node_agent/node_sync/__init__.py index 7a3bfb23..15d652f5 100644 --- a/tendrl/node_agent/node_sync/__init__.py +++ b/tendrl/node_agent/node_sync/__init__.py @@ -25,17 +25,6 @@ "ceph-osd@*" ] -TENDRL_SERVICE_TAGS = { - "tendrl-node-agent": "tendrl/node", - "etcd": "tendrl/central-store", - "tendrl-apid": "tendrl/server", - "tendrl-gluster-integration": "tendrl/integration/gluster", - "tendrl-ceph-integration": "tendrl/integration/ceph", - "glusterd": "gluster/server", - "ceph-mon": "ceph/mon", - "ceph-osd": "ceph/osd" -} - class NodeAgentSyncThread(sds_sync.StateSyncThread): def _run(self): @@ -49,10 +38,9 @@ def _run(self): while not self._complete.is_set(): try: priority = "debug" - interval = 10 + interval = 2 if NS.first_node_inventory_sync: priority = "info" - interval = 2 NS.first_node_inventory_sync = False gevent.sleep(interval) @@ -68,7 +56,10 @@ def _run(self): for service in TENDRL_SERVICES: s = NS.tendrl.objects.Service(service=service) if s.running: - tags.append(TENDRL_SERVICE_TAGS[service.strip("@*")]) + service_tag = NS.compiled_definitions.get_parsed_defs()[ + 'namespace.tendrl' + ]['tags'][service.strip("@*")] + tags.append(service_tag) s.save() gevent.sleep(interval)