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

Check project and inventory source update cache timeout when deciding

Browse Source 
whether or not to spawn an instance of either one as a dependency
This commit is contained in:
Matthew Jones
2014-03-25 16:21:46 -04:00
parent 1dc3aa8ab1
commit 74602f1009
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
awx/main/models/jobs.py
View File

@@ -312,11 +312,13 @@ class Job(UnifiedJob, JobOptions):
if obj.inventory_source in inventory_sources: if obj.inventory_source in inventory_sources:
inventory_sources_found.append(obj.inventory_source) inventory_sources_found.append(obj.inventory_source)
if not project_found and self.project.scm_update_on_launch: if not project_found and self.project.scm_update_on_launch:
dependencies.append(self.project.create_project_update(launch_type='dependency')) if not self.project.last_job_run + datetime.timedelta(seconds=self.project.scm_update_cache_timeout) > now():
dependencies.append(self.project.create_project_update(launch_type='dependency'))
if inventory_sources.count(): # and not has_setup_failures? Probably handled as an error scenario in the task runner if inventory_sources.count(): # and not has_setup_failures? Probably handled as an error scenario in the task runner
for source in inventory_sources: for source in inventory_sources:
if not source in inventory_sources_found: if not source in inventory_sources_found:
dependencies.append(source.create_inventory_update(launch_type='dependency')) if not source.last_job_run + datetime.timedelta(seconds=source.update_cache_timeout) > now():
dependencies.append(source.create_inventory_update(launch_type='dependency'))
return dependencies return dependencies
def signal_start(self, **kwargs): def signal_start(self, **kwargs):