Add source_channel to Orquesta context

Author: LindsayHill

contrib/runners/orquesta_runner/orquesta_runner/orquesta_runner.py

@@ -76,6 +76,9 @@ def _construct_st2_context(self):
         if self.execution.context.get('api_user'):
             st2_ctx['st2']['api_user'] = self.execution.context.get('api_user')
 
+        if self.execution.context.get('source_channel'):
+            st2_ctx['st2']['source_channel'] = self.execution.context.get('source_channel')
+
         if self.execution.context:
             st2_ctx['parent'] = self.execution.context
 

st2common/st2common/services/workflows.py

@@ -568,6 +568,9 @@ def request_action_execution(wf_ex_db, task_ex_db, st2_ctx, ac_ex_req, delay=Non
     if st2_ctx.get('api_user'):
         ac_ex_ctx['api_user'] = st2_ctx.get('api_user')
 
+    if st2_ctx.get('source_channel'):
+        ac_ex_ctx['source_channel'] = st2_ctx.get('source_channel')
+
     if item_id is not None:
         ac_ex_ctx['orquesta']['item_id'] = item_id
 
@@ -921,6 +924,9 @@ def request_next_tasks(wf_ex_db, task_ex_id=None):
                 if root_st2_ctx.get('api_user'):
                     st2_ctx['api_user'] = root_st2_ctx.get('api_user')
 
+                if root_st2_ctx.get('source_channel'):
+                    st2_ctx['source_channel'] = root_st2_ctx.get('source_channel')
+
                 # Request the task execution.
                 request_task_execution(wf_ex_db, st2_ctx, task)
             except Exception as e: