@@ -24,16 +24,19 @@ def __init__(self, redis, logger, console_logger=None):
24
24
"""
25
25
super ().__init__ (redis , logger , console_logger )
26
26
27
+ # Should run user input
27
28
#def run_userinput(self, sms, email, subflow, argument):
28
29
# url = "%s/api/v1/workflows/%s/execute" % (self.url, workflow)
29
30
30
31
# if len(sms) > 0:
31
32
32
- def run_subflow (self , user_apikey , workflow , argument , source_workflow = "" , source_execution = "" , source_node = "" , source_auth = "" , startnode = "" ):
33
+ def run_subflow (self , user_apikey , workflow , argument , source_workflow = "" , source_execution = "" , source_node = "" , source_auth = "" , startnode = "" , backend_url = "" ):
33
34
#print("STARTNODE: %s" % startnode)
34
35
url = "%s/api/v1/workflows/%s/execute" % (self .url , workflow )
35
36
36
- params = {}
37
+ params = {
38
+ "User-Agent" : "Subflow 1.0.0"
39
+ }
37
40
if len (str (source_workflow )) > 0 :
38
41
params ["source_workflow" ] = source_workflow
39
42
else :
@@ -59,6 +62,11 @@ def run_subflow(self, user_apikey, workflow, argument, source_workflow="", sourc
59
62
else :
60
63
print ("No startnode" )
61
64
65
+ if len (str (backend_url )) > 0 :
66
+ url = "%s/api/v1/workflows/%s/execute" % (backend_url , workflow )
67
+ print ("[INFO] Changed URL to %s for this execution" % url )
68
+
69
+
62
70
headers = {
63
71
"Authorization" : "Bearer %s" % user_apikey ,
64
72
}
0 commit comments