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

Merge pull request #8206 from ryanpetrello/more-bulk-update-last-job

Browse Source 
change host -> last_job_id bulk update query to avoid locking issues

Reviewed-by: https://github.com/apps/softwarefactory-project-zuul
This commit is contained in:
softwarefactory-project-zuul[bot]
2020-09-23 15:18:42 +00:00
committed by GitHub
parent d7ca49ce4a 89ff8e1f3e
commit aac17b9d2c
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
awx/main/models/events.py
View File

@@ -533,13 +533,21 @@ class JobEvent(BasePlaybookEvent):
(summary['host_id'], summary['id']) (summary['host_id'], summary['id'])
for summary in JobHostSummary.objects.filter(job_id=job.id).values('id', 'host_id') for summary in JobHostSummary.objects.filter(job_id=job.id).values('id', 'host_id')
) )
updated_hosts = set()
for h in all_hosts: for h in all_hosts:
# if the hostname *shows up* in the playbook_on_stats event # if the hostname *shows up* in the playbook_on_stats event
if h.name in hostnames: if h.name in hostnames:
h.last_job_id = job.id h.last_job_id = job.id
updated_hosts.add(h)
if h.id in host_mapping: if h.id in host_mapping:
h.last_job_host_summary_id = host_mapping[h.id] h.last_job_host_summary_id = host_mapping[h.id]
Host.objects.bulk_update(all_hosts, ['last_job_id', 'last_job_host_summary_id']) updated_hosts.add(h)
Host.objects.bulk_update(
list(updated_hosts),
['last_job_id', 'last_job_host_summary_id'],
batch_size=100
)
@property @property