External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-01-19 05:31:22 -03:30
Code Issues Packages Projects Releases Wiki Activity

Invalidate the cache on a new project revision

Browse Source
This commit is contained in:
Bill Nottingham 2020-05-29 17:31:21 -04:00 committed by AlanCoding
parent d272ee3521
commit 1f4c46d873
No known key found for this signature in database
GPG Key ID: D0E673F5E7053218
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
awx/main/tasks.py
View File

@ -2333,6 +2333,20 @@ class RunProjectUpdate(BaseTask):
else:
self.original_branch = git_repo.active_branch
def clear_project_cache(self, instance, revision):
cache_dir = instance.get_cache_path()
if os.path.isdir(cache_dir):
for entry in os.listdir(cache_dir):
old_path = os.path.join(cache_dir, entry)
if entry != revision:
# invalidate, then delete
new_path = os.path.join(cache_dir,'.~~delete~~' + entry)
try:
os.rename(old_path, new_path)
shutil.rmtree(new_path)
except OSError:
logger.warning(f"Could not remove cache directory {old_path}")
@staticmethod
def make_local_copy(project_path, destination_folder, scm_type, scm_revision):
if scm_type == 'git':
@ -2366,6 +2380,7 @@ class RunProjectUpdate(BaseTask):
# To avoid hangs, very important to release lock even if errors happen here
try:
if self.playbook_new_revision:
self.clear_project_cache(instance, self.playbook_new_revision)
instance.scm_revision = self.playbook_new_revision
instance.save(update_fields=['scm_revision'])
if self.job_private_data_dir: