diff --git a/src/provisioner/provisioner.py b/src/provisioner/provisioner.py index 2a270f49e..ed173bdf7 100644 --- a/src/provisioner/provisioner.py +++ b/src/provisioner/provisioner.py @@ -467,8 +467,8 @@ def _update_provisioning_status(cortx_conf: MappedConf, node_id: str, node_id: machine-id phase: deployment/upgrade status: default/progress/success/error.""" - key_prefix = f'node>{node_id}>provisioning>' - keys = [(key_prefix + 'phase', phase), (key_prefix + 'status', status)] + key_prefix = f'node>{node_id}>provisioning' + keys = [(key_prefix + '>' + 'phase', phase), (key_prefix + '>' + 'status', status)] cortx_conf.set_kvs(keys) # TODO: Remove the following section once gconf is moved to consul completely. @@ -476,7 +476,7 @@ def _update_provisioning_status(cortx_conf: MappedConf, node_id: str, Conf.set(CortxProvisioner._cortx_gconf_consul_index, f'{key_prefix}>phase', phase) Conf.set(CortxProvisioner._cortx_gconf_consul_index, f'{key_prefix}>status', status) if phase is ProvisionerStages.DEPLOYMENT.value: - cortx_conf.set(f'node>{node_id}>provisioning>time', int(time.time())) + cortx_conf.set(f'{key_prefix}>time', int(time.time())) Conf.set(CortxProvisioner._cortx_gconf_consul_index, f'{key_prefix}>time', int(time.time())) Conf.save(CortxProvisioner._cortx_gconf_consul_index)