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

emit job status over socket after database commit

Browse Source 
* Wait until the newly created job record hits the database before
telling the websocket clients that the job's status is "pending"
This commit is contained in:
Chris Meyers
2017-02-28 12:39:55 -05:00
parent cdb757503e
commit 7da52c8bef
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
awx/main/models/unified_jobs.py
View File

@@ -964,10 +964,13 @@ class UnifiedJob(PolymorphicModel, PasswordFieldsModel, CommonModelNameNotUnique
# Save the pending status, and inform the SocketIO listener. # Save the pending status, and inform the SocketIO listener.
self.update_fields(start_args=json.dumps(kwargs), status='pending') self.update_fields(start_args=json.dumps(kwargs), status='pending')
self.websocket_emit_status("pending")
from awx.main.scheduler.tasks import run_job_launch def post_commit():
connection.on_commit(lambda: run_job_launch.delay(self.id)) from awx.main.scheduler.tasks import run_job_launch
self.websocket_emit_status("pending")
run_job_launch.delay(self.id)
connection.on_commit(post_commit)
# Each type of unified job has a different Task class; get the # Each type of unified job has a different Task class; get the
# appropirate one. # appropirate one.