Merge "Fix job book deletion issue in taskflow" into stable/wallaby

This commit is contained in:
Zuul
2024-01-23 16:11:34 +00:00
committed by Gerrit Code Review

View File

@@ -147,12 +147,13 @@ class DynamicLoggingConductor(impl_blocking.BlockingConductor):
if (not CONF.task_flow.jobboard_save_logbook and if (not CONF.task_flow.jobboard_save_logbook and
job.state == states.COMPLETE): job.state == states.COMPLETE):
LOG.debug("Job %s is complete. Cleaning up job logbook.", job.name) LOG.debug("Job %s is complete. Cleaning up job logbook.", job.name)
try: if job.book:
self._persistence.get_connection().destroy_logbook( try:
job.book.uuid) self._persistence.get_connection().destroy_logbook(
except taskflow_exc.NotFound: job.book.uuid)
LOG.debug("Logbook for job %s has been already cleaned up", except taskflow_exc.NotFound:
job.name) LOG.debug("Logbook for job %s has been already cleaned up",
job.name)
class RedisDynamicLoggingConductor(DynamicLoggingConductor): class RedisDynamicLoggingConductor(DynamicLoggingConductor):