Add integration tests to cover pause, resume, and cancel for task with items

Add integration tests to cover cancellation, pause, and resume of orquesta workflows that have tasks with items.

Author: m4dcoder

contrib/examples/actions/orquesta-test-with-items-concurrency.yaml

@@ -0,0 +1,12 @@
+---
+name: orquesta-test-with-items
+description: A workflow for testing with items and concurrency.
+runner_type: orquesta
+entry_point: workflows/tests/orquesta-test-with-items.yaml
+enabled: true
+parameters:
+  tempfiles:
+    required: true
+    type: array
+  concurrency:
+    type: integer

contrib/examples/actions/orquesta-test-with-items.yaml

@@ -1,15 +1,16 @@
 version: 1.0
 
-description: A workflow demonstrating with items and concurrent processing.
+description: A workflow for testing with items and concurrency.
 
 input:
   - tempfiles
+  - concurrency: <% len(ctx(tempfiles)) %>
 
 tasks:
   task1:
     with:
       items: tempfile in <% ctx(tempfiles) %>
-      concurrency: 2
+      concurrency: <% ctx(concurrency) %>
     action: core.local
     input:
       cmd: "while [ -e '<% item(tempfile) %>' ]; do sleep 0.1; done"

contrib/examples/actions/workflows/tests/orquesta-test-with-items-concurrency.yaml renamed to contrib/examples/actions/workflows/tests/orquesta-test-with-items.yaml

@@ -134,7 +134,7 @@ def pause(self):
 
     def resume(self):
         # Resume the target workflow.
-        wf_svc.request_resume(self.execution)
+        wf_ex_db = wf_svc.request_resume(self.execution)
 
         # Request resume of tasks that are workflows and still running.
         for child_ex_id in self.execution.children:
@@ -147,7 +147,7 @@ def resume(self):
                 )
 
         return (
-            ac_const.LIVEACTION_STATUS_RUNNING,
+            wf_ex_db.status if wf_ex_db else ac_const.LIVEACTION_STATUS_RUNNING,
             self.liveaction.result,
             self.liveaction.context
         )