From 3cfe544ada01bc9b12753a692c21fad046433920 Mon Sep 17 00:00:00 2001
From: AlanCoding <arominge@redhat.com>
Date: Wed, 12 Oct 2016 13:54:13 -0400
Subject: [PATCH] update workflows to work with new channels implementation

---
 awx/main/models/workflow.py | 2 +-
 awx/main/tasks.py           | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/awx/main/models/workflow.py b/awx/main/models/workflow.py
index 91983ca673..62224b9509 100644
--- a/awx/main/models/workflow.py
+++ b/awx/main/models/workflow.py
@@ -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
 
diff --git a/awx/main/tasks.py b/awx/main/tasks.py
index 05a172b6da..22129135fb 100644
--- a/awx/main/tasks.py
+++ b/awx/main/tasks.py
@@ -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
 '''