when releasing receptor work, do so in try/except

This commit is contained in:
Jim Ladd 2021-10-15 16:45:21 -07:00 committed by Shane McDonald
parent 056247a34a
commit d1fecc11c9
No known key found for this signature in database
GPG Key ID: 6F374AF6E9EB9374

View File

@ -3071,7 +3071,13 @@ class AWXReceptorJob:
finally:
# Make sure to always release the work unit if we established it
if self.unit_id is not None and settings.RECEPTOR_RELEASE_WORK:
receptor_ctl.simple_command(f"work release {self.unit_id}")
try:
receptor_ctl.simple_command(f"work release {self.unit_id}")
except RuntimeError:
logger.exception(f"Unable to release work item {self.unit_id}")
# If an error occured without the job itself failing, it could be a broken instance
if self.work_type == 'ansible-runner' and ((res is None) or (getattr(res, 'rc', None) is None)):
execution_node_health_check.delay(self.task.instance.execution_node)
@property
def sign_work(self):