Merge "improve logging for job execution failure"
This commit is contained in:
commit
850a7b0e6f
@ -136,8 +136,8 @@ def run_job(job_execution_id):
|
|||||||
try:
|
try:
|
||||||
_run_job(job_execution_id)
|
_run_job(job_execution_id)
|
||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
LOG.warning(
|
LOG.exception(
|
||||||
_LW("Can't run job execution (reason: {reason})").format(
|
_LE("Can't run job execution (reason: {reason})").format(
|
||||||
reason=ex))
|
reason=ex))
|
||||||
|
|
||||||
job_execution = conductor.job_execution_get(
|
job_execution = conductor.job_execution_get(
|
||||||
@ -218,8 +218,8 @@ def update_job_status(job_execution_id):
|
|||||||
try:
|
try:
|
||||||
get_job_status(job_execution_id)
|
get_job_status(job_execution_id)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
LOG.error(_LE("Error during update job execution {job}: {error}")
|
LOG.exception(_LE("Error during update job execution {job}: {error}")
|
||||||
.format(job=job_execution_id, error=e))
|
.format(job=job_execution_id, error=e))
|
||||||
|
|
||||||
|
|
||||||
def update_job_statuses(cluster_id=None):
|
def update_job_statuses(cluster_id=None):
|
||||||
|
Loading…
Reference in New Issue
Block a user