openstack
/
octavia
Code Issues Proposed changes

Add missing log line for finishing amp operations 

Both amp config and amp cert rotate were missing Finished log lines.

Change-Id: I86add89ed7ea474dcb24962547c78460bc2e260c
This commit is contained in:
Adam Harwell 2020-08-11 16:36:49 -07:00 committed by Ann Taraday
parent a5f0524fd0
commit 6b182b50cd
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
octavia/controller/worker/v1/controller_worker.py
View File

@ -1110,7 +1110,8 @@ class ControllerWorker(base_taskflow.BaseTaskFlowEngine):
amp = self._amphora_repo.get(db_apis.get_session(),
id=amphora_id)
LOG.info("Start amphora cert rotation, amphora's id is: %s", amp.id)
LOG.info("Start amphora cert rotation, amphora's id is: %s",
amphora_id)
certrotation_amphora_tf = self.taskflow_load(
self._amphora_flows.cert_rotate_amphora_flow(),
@ -1120,6 +1121,8 @@ class ControllerWorker(base_taskflow.BaseTaskFlowEngine):
with tf_logging.DynamicLoggingListener(certrotation_amphora_tf,
log=LOG):
certrotation_amphora_tf.run()
LOG.info("Finished amphora cert rotation, amphora's id was: %s",
amphora_id)
def update_amphora_agent_config(self, amphora_id):
"""Update the amphora agent configuration.
@ -1149,3 +1152,5 @@ class ControllerWorker(base_taskflow.BaseTaskFlowEngine):
with tf_logging.DynamicLoggingListener(update_amphora_tf,
log=LOG):
update_amphora_tf.run()
LOG.info("Finished amphora agent configuration update, amphora's id "
"was: %s", amphora_id)

7
octavia/controller/worker/v2/controller_worker.py
View File

@ -977,7 +977,8 @@ class ControllerWorker(object):
amp = self._amphora_repo.get(db_apis.get_session(),
id=amphora_id)
LOG.info("Start amphora cert rotation, amphora's id is: %s", amp.id)
LOG.info("Start amphora cert rotation, amphora's id is: %s",
amphora_id)
store = {constants.AMPHORA: amp.to_dict(),
constants.AMPHORA_ID: amphora_id}
@ -985,6 +986,8 @@ class ControllerWorker(object):
self.run_flow(
flow_utils.cert_rotate_amphora_flow,
store=store)
LOG.info("Finished amphora cert rotation, amphora's id was: %s",
amphora_id)
def update_amphora_agent_config(self, amphora_id):
"""Update the amphora agent configuration.
@ -1012,3 +1015,5 @@ class ControllerWorker(object):
self.run_flow(
flow_utils.update_amphora_config_flow,
store=store)
LOG.info("Finished amphora agent configuration update, amphora's id "
"was: %s", amphora_id)