Send a message every time we get the stack

This allows clients to get live updates on the stack status when the
workflow gets them. Otherwise they will need to wait for the workflow
and poll the stack.

Change-Id: I55945adb5bd7d3159248e262f4b510c59c897ebb

workbooks/deployment.yaml

@@ -196,7 +196,10 @@ workflows:
         on-error: set_deployment_failed
 
       wait_for_stack_complete:
-        workflow: tripleo.stack.v1.wait_for_stack_complete_or_failed stack=<% $.container %>
+        workflow: tripleo.stack.v1.wait_for_stack_complete_or_failed
+        input:
+          stack: <% $.container %>
+          queue_name: <% $.queue_name %>
         publish-on-error:
           message: <% task().result %>
         publish:

workbooks/stack.yaml

@@ -5,10 +5,37 @@ description: TripleO Stack Workflows
 
 workflows:
 
+  _heat_stacks_get:
+
+    tags:
+      - tripleo-common-managed
+
+    input:
+      - stack
+      - queue_name: null
+
+    tasks:
+      heat_stacks_get:
+        action: heat.stacks_get stack_id=<% $.stack %>
+        publish:
+          stack: <% task().result %>
+        on-success:
+          - send_message: <% bool($.queue_name) %>
+      send_message:
+        workflow: tripleo.messaging.v1.send
+        input:
+          queue_name: <% $.queue_name %>
+          type: <% execution().name %>
+          status: "RUNNING"  # This should never be the end of a workflow
+          execution: <% execution() %>
+          payload:
+            stack: <% task(heat_stacks_get).result %>
+
   wait_for_stack_complete_or_failed:
     input:
       - stack
       - timeout: 14400 # 4 hours. Default timeout of stack deployment
+      - queue_name: null
 
     tags:
       - tripleo-common-managed
@@ -16,19 +43,23 @@ workflows:
     tasks:
 
       wait_for_stack_status:
-        action: heat.stacks_get stack_id=<% $.stack %>
+        workflow: _heat_stacks_get
+        input:
+          stack: <% $.stack %>
+          queue_name: <% $.queue_name %>
         timeout: <% $.timeout %>
         publish:
-          stack_status: <% task().result.stack_status %>
+          stack_status: <% task().result.stack.stack_status %>
         retry:
           delay: 15
           count: <% $.timeout / 15 %>
-          continue-on: <% task().result.stack_status in ['CREATE_IN_PROGRESS', 'UPDATE_IN_PROGRESS', 'DELETE_IN_PROGRESS'] %>
+          continue-on: <% task().result.stack.stack_status in ['CREATE_IN_PROGRESS', 'UPDATE_IN_PROGRESS', 'DELETE_IN_PROGRESS'] %>
 
   wait_for_stack_in_progress:
     input:
       - stack
       - timeout: 600 # 10 minutes. Should not take much longer for a stack to transition to IN_PROGRESS
+      - queue_name: null
 
     tags:
       - tripleo-common-managed
@@ -36,12 +67,17 @@ workflows:
     tasks:
 
       wait_for_stack_status:
-        action: heat.stacks_get stack_id=<% $.stack %>
+        workflow: _heat_stacks_get
+        input:
+          stack: <% $.stack %>
+          queue_name: <% $.queue_name %>
         timeout: <% $.timeout %>
+        publish:
+          stack_status: <% task().result.stack.stack_status %>
         retry:
           delay: 15
           count: <% $.timeout / 15 %>
-          continue-on: <% task().result.stack_status in ['CREATE_COMPLETE', 'CREATE_FAILED', 'UPDATE_COMPLETE', 'UPDATE_FAILED', 'DELETE_FAILED'] %>
+          continue-on: <% task().result.stack.stack_status in ['CREATE_COMPLETE', 'CREATE_FAILED', 'UPDATE_COMPLETE', 'UPDATE_FAILED', 'DELETE_FAILED'] %>
 
   wait_for_stack_does_not_exist:
     input: