[cli] Renames ret_output flag to return_output

Author: grussorusso

internal/cli/cli.go

@@ -124,7 +124,7 @@ func Init() {
 	invokeCmd.Flags().StringSliceVarP(&params, "param", "p", nil, "Function parameter: <name>:<value>")
 	invokeCmd.Flags().StringVarP(&paramsFile, "params_file", "j", "", "File containing parameters (JSON)")
 	invokeCmd.Flags().BoolVarP(&asyncInvocation, "async", "a", false, "Asynchronous invocation")
-	invokeCmd.Flags().BoolVarP(&returnOutput, "ret_output", "o", false, "Capture function output (if supported by used runtime)")
+	invokeCmd.Flags().BoolVarP(&returnOutput, "return_output", "o", false, "Capture function output (if supported by used runtime)")
 
 	rootCmd.AddCommand(createCmd)
 	createCmd.Flags().BoolVarP(&update, "update", "u", false, "Overwrite any function with the same name")

internal/workflow/remote_offloading_policy.go

@@ -276,13 +276,13 @@ func prepareParameters(r *Request, p *Progress) *remotePolicyParams {
 	}
 
 	// Bandwidth (we assume identical)
-	dsBandwidth := config.GetFloat(config.WORKFLOW_OFFLOADING_POLICY_NODE_TO_DATA_STORE_BANDWIDTH, 100.0)
+	dsBandwidth := config.GetFloat(config.WORKFLOW_OFFLOADING_POLICY_NODE_TO_DATA_STORE_BANDWIDTH, 40.0)
 	for _, n := range params.EdgeNodes {
 		params.DSBandwidth[n] = dsBandwidth
 	}
 
 	if len(params.CloudNodes) > 0 {
-		params.DSBandwidth[CLOUD] = config.GetFloat(config.WORKFLOW_OFFLOADING_POLICY_CLOUD_TO_DATA_STORE_BANDWIDTH, dsBandwidth*10)
+		params.DSBandwidth[CLOUD] = config.GetFloat(config.WORKFLOW_OFFLOADING_POLICY_CLOUD_TO_DATA_STORE_BANDWIDTH, 1000)
 	}
 
 	// Execution Times