External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-02-28 00:08:44 -03:30
Code Issues Packages Projects Releases Wiki Activity

add log message if unable to open lockfile

Browse Source 
Signed-off-by: Jose Angel Morena <jmorenas@redhat.com>
This commit is contained in:
Jose Angel Morena
2023-01-10 21:51:23 +01:00
parent d73cc501d5
commit ce0a456ecc
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
awx/main/tasks/jobs.py
View File

@@ -390,6 +390,7 @@ class BaseTask(object):
logger.error("I/O error({0}) while trying to open lock file [{1}]: {2}".format(e.errno, lock_path, e.strerror)) logger.error("I/O error({0}) while trying to open lock file [{1}]: {2}".format(e.errno, lock_path, e.strerror))
raise raise
emitted_lockfile_log = False
start_time = time.time() start_time = time.time()
while True: while True:
try: try:
@@ -401,6 +402,9 @@ class BaseTask(object):
logger.error("I/O error({0}) while trying to aquire lock on file [{1}]: {2}".format(e.errno, lock_path, e.strerror)) logger.error("I/O error({0}) while trying to aquire lock on file [{1}]: {2}".format(e.errno, lock_path, e.strerror))
raise raise
else: else:
if not emitted_lockfile_log:
logger.info(f"exception acquiring lock {lock_path}: {e}")
emitted_lockfile_log = True
time.sleep(1.0) time.sleep(1.0)
self.instance.refresh_from_db(fields=['cancel_flag']) self.instance.refresh_from_db(fields=['cancel_flag'])
if self.instance.cancel_flag or signal_callback(): if self.instance.cancel_flag or signal_callback():