Fix log messages in the action heartbeats mechanism
Change-Id: Ic1293db03d020f321d4e009ab7906da7622c5daf
This commit is contained in:
parent
a9b19b5f25
commit
7b58b9c267
|
@ -88,7 +88,7 @@ def _loop():
|
||||||
handle_expired_actions()
|
handle_expired_actions()
|
||||||
except Exception:
|
except Exception:
|
||||||
LOG.exception(
|
LOG.exception(
|
||||||
'Action execution checker iteration failed'
|
'Action heartbeat checker iteration failed'
|
||||||
' due to an unexpected exception.'
|
' due to an unexpected exception.'
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -109,14 +109,14 @@ def start():
|
||||||
enabled = interval and max_missed
|
enabled = interval and max_missed
|
||||||
|
|
||||||
if not enabled:
|
if not enabled:
|
||||||
LOG.info("Action heartbeat reporting is disabled.")
|
LOG.info("Action heartbeats are disabled.")
|
||||||
|
|
||||||
return
|
return
|
||||||
|
|
||||||
wait_time = interval * max_missed
|
wait_time = interval * max_missed
|
||||||
|
|
||||||
LOG.debug(
|
LOG.debug(
|
||||||
"First run of action execution checker, wait before "
|
"First run of action heartbeat checker, wait before "
|
||||||
"checking to make sure executors have time to send "
|
"checking to make sure executors have time to send "
|
||||||
"heartbeats. ({} seconds)".format(wait_time)
|
"heartbeats. ({} seconds)".format(wait_time)
|
||||||
)
|
)
|
||||||
|
|
|
@ -50,7 +50,7 @@ def remove_action(action_ex_id):
|
||||||
|
|
||||||
|
|
||||||
def send_action_heartbeats():
|
def send_action_heartbeats():
|
||||||
LOG.debug('Running heartbeat reporter...')
|
LOG.debug('Running heartbeat sender...')
|
||||||
|
|
||||||
global _running_actions
|
global _running_actions
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue