Improved response collection across operation items

core/runtime/recursive.py

@@ -1,17 +1,27 @@
 from core.execution.action.action import buildAction
+from plugins.rmass.actions import synapsenotify
 
-def recursiveSet(definition, outputs):
+def recursiveSet(definition, outputs, responses):
     recursiveset = definition.recursiveset["actions"]
     for item in outputs[definition.recursiveset["source"]]:
         outputs[definition.recursiveset["outputlabel"]] = item
-        #outputs["recursive"] = item
-        print("DEBUGGING recursiveset item")
-        print(outputs[definition.recursiveset["outputlabel"]])
+
+        #print("DEBUGGING recursiveset item")
+        #print(outputs[definition.recursiveset["outputlabel"]])
 
         for job in recursiveset:
             outputs, response = buildAction(job, outputs)
+            responses.append(response)
 
-    return outputs
+            #response_data = response.json()
+            #print(f"RECURSIVESET {job.name} DEBUG")
+            #print(response_data)
+    
+            #if response.status_code != 200:
+                #outputs, response = buildAction(synapsenotify, outputs)
+                #print("GETRMASSMESSAGEIDDEBUG")
+                #print(outputs)
+    return outputs, responses
 
 from core.execution.action.action import buildAction