Merge branch 'master' into reprocleanup

daliuge-engine/dlg/apps/bash_shell_app.py

@@ -222,17 +222,31 @@ def _run_bash(self, inputs, outputs, stdin=None, stdout=subprocess.PIPE):
         keyargs = {arg:appArgs[arg]["value"] for arg in appArgs if not appArgs[arg]["positional"]}
         logger.debug("pargs: %s; keyargs: %s, appArgs: %s",pargs, keyargs, appArgs)
         if "inputs" in self.parameters and isinstance(self.parameters['inputs'][0], dict):
-            keyargs = droputils.identify_named_ports(
+            pkeyargs = droputils.identify_named_ports(
                             inputs_dict,
                             self.parameters["inputs"],
                             pargs,
                             pargsDict,
                             appArgs,
                             check_len=len(inputs),
                             mode="inputs")
+            keyargs.update(pkeyargs)
         else:
             for i in range(min(len(inputs), len(pargs))):
                 keyargs.update({pargs[i]: list(inputs.values())[i]})
+        if "outputs" in self.parameters and isinstance(self.parameters['outputs'][0], dict):
+            pkeyargs = droputils.identify_named_ports(
+                            outputs_dict,
+                            self.parameters["outputs"],
+                            pargs,
+                            pargsDict,
+                            appArgs,
+                            check_len=len(outputs),
+                            mode="outputs")
+            keyargs.update(pkeyargs)
+        else:
+            for i in range(min(len(outputs), len(pargs))):
+                keyargs.update({pargs[i]: list(outputs.values())[i]})
         keyargs = droputils.serialize_kwargs(keyargs, 
             prefix=self._argumentPrefix,
             separator=self._paramValueSeparator)

daliuge-engine/dlg/droputils.py

@@ -583,7 +583,7 @@ def identify_named_ports(ports, port_dict, posargs, pargsDict, appArgs, check_le
     for i in range(check_len):
         # key for final dict is value in named ports dict
         key = list(port_dict[i].values())[0]
-        # value for final dict is value in inputs dict
+        # value for final dict is value in ports dict
         value = ports[list(port_dict[i].keys())[0]]
         if not value: value = '' # make sure we are passing NULL drop events
         if key in posargs:

daliuge-translator/dlg/dropmake/web/main.js

@@ -60,11 +60,19 @@ function openSettingsModal(){
     $('#settingsModal').modal("show")
 }
 
-async function initiateDeploy(method, selected, name){
+async function initiateDeploy(method, selected, clickedName){
+    var clickedUrl
+    JSON.parse(window.localStorage.getItem("deployMethods")).forEach(element => {
+        if(element.name === clickedName){
+            clickedUrl = element.url
+        }
+    })
+
     if (selected === false){
-        changeSelectedDeployMethod(name)
+        await changeSelectedDeployMethod(clickedName, clickedUrl)
     }
-    var activeUrlReachable = await checkUrlStatus(window.localStorage.getItem("manager_url"))
+
+    var activeUrlReachable = await checkUrlStatus(clickedUrl)
 
     if(!activeUrlReachable){
         $("#warning-alert").fadeTo(2000, 1000).slideUp(200, function() {
@@ -85,16 +93,20 @@ async function initiateDeploy(method, selected, name){
     }
 }
 
-function changeSelectedDeployMethod(name) {
-    var deployMethodsArray = JSON.parse(localStorage.getItem("deployMethods"))
-    deployMethodsArray.forEach(element => {
-        element.active = "false"
-        if(element.name === name){
-            element.active = "true"
-        }
+async function changeSelectedDeployMethod(name,manager_url) {
+    return new Promise((resolve, reject) => {
+        var deployMethodsArray = JSON.parse(localStorage.getItem("deployMethods"))
+        $("#managerUrlInput").val(manager_url);
+        deployMethodsArray.forEach(element => {
+            element.active = "false"
+            if(element.name === name){
+                element.active = "true"
+            }
+        })
+        window.localStorage.setItem('deployMethods', JSON.stringify(deployMethodsArray))
+        updateDeployOptionsDropdown()
+        resolve(true)
     })
-    localStorage.setItem('deployMethods', JSON.stringify(deployMethodsArray))
-    updateDeployOptionsDropdown()
 }
 
 function updateDeployOptionsDropdown() {

tools/xml2palette/xml2palette.py

@@ -95,8 +95,15 @@ def check_environment_variables():
         value = os.environ.get(variable)
 
         if value is None:
-            logging.error("No " + variable + " environment variable.")
-            return False
+            if variable == 'PROJECT_NAME':
+                os.environ['PROJECT_NAME'] = os.path.basename(os.path.abspath('.'))
+            elif variable == 'PROJECT_VERSION':
+                os.environ['PROJECT_VERSION'] = '0.1'
+            elif variable == 'GIT_REPO':
+                os.environ['GIT_REPO'] = os.environ['PROJECT_NAME']
+            else:
+                logging.error("No " + variable + " environment variable.")
+                return False
 
     return True
 
@@ -1063,6 +1070,10 @@ def params_to_nodes(params):
         level=logging.INFO,
     )
 
+    # read environment variables
+    if not check_environment_variables():
+        sys.exit(1)
+
     logging.info("PROJECT_NAME:" + os.environ.get("PROJECT_NAME"))
     logging.info("PROJECT_VERSION:" + os.environ.get("PROJECT_VERSION"))
     logging.info("GIT_REPO:" + os.environ.get("GIT_REPO"))
@@ -1077,10 +1088,6 @@ def params_to_nodes(params):
     # create a temp directory for the output of doxygen
     output_directory = tempfile.TemporaryDirectory()
 
-    # read environment variables
-    if not check_environment_variables():
-        sys.exit(1)
-
     # add extra doxygen setting for input and output locations
     DOXYGEN_SETTINGS.append(("PROJECT_NAME", os.environ.get("PROJECT_NAME")))
     DOXYGEN_SETTINGS.append(("INPUT", inputdir))