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

update workflows to work with new channels implementation

Browse Source
This commit is contained in:
AlanCoding 2016-10-12 13:54:13 -04:00
parent 2488e1e3f0
commit 3cfe544ada
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
awx/main/models/workflow.py
View File

@ -384,6 +384,6 @@ class WorkflowJob(UnifiedJob, WorkflowJobOptions, JobNotificationMixin, Workflow
if res:
self.status = 'running'
self.save()
self.socketio_emit_status("running")
self.websocket_emit_status("running")
return res

4
awx/main/tasks.py
View File

@ -1685,7 +1685,7 @@ class RunWorkflowJob(BaseTask):
def run(self, pk, **kwargs):
#Run the job/task and capture its output.
instance = self.update_model(pk, status='running', celery_task_id=self.request.id)
instance.socketio_emit_status("running")
instance.websocket_emit_status("running")
# FIXME: Currently, the workflow job busy waits until the graph run is
# complete. Instead, the workflow job should return or never even run,
@ -1707,6 +1707,6 @@ class RunWorkflowJob(BaseTask):
instance = self.update_model(instance.pk, status='successful')
break
time.sleep(1)
instance.socketio_emit_status(instance.status)
instance.websocket_emit_status(instance.status)
# TODO: Handle cancel
'''