ovh
diff --git a/‎engine/api/workflow/execute_node_job_run.go
Lines changed: 7 additions & 1 deletion b/‎engine/api/workflow/execute_node_job_run.go
Lines changed: 7 additions & 1 deletion
diff --git a/‎engine/api/workflow_queue.go
Lines changed: 1 addition & 1 deletion b/‎engine/api/workflow_queue.go
Lines changed: 1 addition & 1 deletion
diff --git a/‎ui/src/app/shared/workflow/wizard/input/wizard.input.component.ts
Lines changed: 5 additions & 0 deletions b/‎ui/src/app/shared/workflow/wizard/input/wizard.input.component.ts
Lines changed: 5 additions & 0 deletions
@@ -324,7 +324,7 @@ func checkStatusWaiting(store cache.Store, jobID int64, status string) error {
 }
 
 // LoadNodeJobRunKeys loads all keys for a job run
-func LoadNodeJobRunKeys(p *sdk.Project, wr *sdk.WorkflowRun, nodeRun *sdk.WorkflowNodeRun) ([]sdk.Parameter, []sdk.Variable, error) {
+func LoadNodeJobRunKeys(db gorp.SqlExecutor, p *sdk.Project, wr *sdk.WorkflowRun, nodeRun *sdk.WorkflowNodeRun) ([]sdk.Parameter, []sdk.Variable, error) {
 	var app *sdk.Application
 	var env *sdk.Environment
 
@@ -333,12 +333,18 @@ func LoadNodeJobRunKeys(p *sdk.Project, wr *sdk.WorkflowRun, nodeRun *sdk.Workfl
 		appMap, has := wr.Workflow.Applications[n.Context.ApplicationID]
 		if has {
 			app = &appMap
+			if err := application.LoadAllBase64Keys(db, app); err != nil {
+				return nil, nil, err
+			}
 		}
 	}
 	if n.Context.EnvironmentID != 0 {
 		envMap, has := wr.Workflow.Environments[n.Context.EnvironmentID]
 		if has {
 			env = &envMap
+			if err := environment.LoadAllBase64Keys(db, env); err != nil {
+				return nil, nil, err
+			}
 		}
 	}
 
 
@@ -180,7 +180,7 @@ func takeJob(ctx context.Context, dbFunc func() *gorp.DbMap, store cache.Store,
 	wnjri.SubNumber = noderun.SubNumber
 	wnjri.Secrets = secrets
 
-	params, secretsKeys, errK := workflow.LoadNodeJobRunKeys(p, workflowRun, noderun)
+	params, secretsKeys, errK := workflow.LoadNodeJobRunKeys(tx, p, workflowRun, noderun)
 	if errK != nil {
 		return nil, sdk.WrapError(errK, "Cannot load keys")
 	}
 
@@ -226,6 +226,11 @@ export class WorkflowWizardNodeInputComponent implements OnInit {
 
         n.context.default_payload = this.editableNode.context.default_payload;
         n.context.default_pipeline_parameters = this.editableNode.context.default_pipeline_parameters;
+        if (n.context.default_pipeline_parameters) {
+            n.context.default_pipeline_parameters.forEach(p => {
+               p.value = p.value.toString();
+            });
+        }
         this.store.dispatch(new UpdateWorkflow({
             projectKey: this.workflow.project_key,
             workflowName: this.workflow.name,
Original file line number	Diff line number	Diff line change
`@@ -324,7 +324,7 @@ func checkStatusWaiting(store cache.Store, jobID int64, status string) error {`
`324`	`324`	`}`
`325`	`325`
`326`	`326`	`// LoadNodeJobRunKeys loads all keys for a job run`
`327`		`-func LoadNodeJobRunKeys(p sdk.Project, wr sdk.WorkflowRun, nodeRun *sdk.WorkflowNodeRun) ([]sdk.Parameter, []sdk.Variable, error) {`
	`327`	`+func LoadNodeJobRunKeys(db gorp.SqlExecutor, p sdk.Project, wr sdk.WorkflowRun, nodeRun *sdk.WorkflowNodeRun) ([]sdk.Parameter, []sdk.Variable, error) {`
`328`	`328`	`var app *sdk.Application`
`329`	`329`	`var env *sdk.Environment`
`330`	`330`
`@@ -333,12 +333,18 @@ func LoadNodeJobRunKeys(p sdk.Project, wr sdk.WorkflowRun, nodeRun *sdk.Workfl`
`333`	`333`	`appMap, has := wr.Workflow.Applications[n.Context.ApplicationID]`
`334`	`334`	`if has {`
`335`	`335`	`app = &appMap`
	`336`	`+ if err := application.LoadAllBase64Keys(db, app); err != nil {`
	`337`	`+ return nil, nil, err`
	`338`	`+ }`
`336`	`339`	`}`
`337`	`340`	`}`
`338`	`341`	`if n.Context.EnvironmentID != 0 {`
`339`	`342`	`envMap, has := wr.Workflow.Environments[n.Context.EnvironmentID]`
`340`	`343`	`if has {`
`341`	`344`	`env = &envMap`
	`345`	`+ if err := environment.LoadAllBase64Keys(db, env); err != nil {`
	`346`	`+ return nil, nil, err`
	`347`	`+ }`
`342`	`348`	`}`
`343`	`349`	`}`
`344`	`350`
Original file line number	Diff line number	Diff line change
`@@ -180,7 +180,7 @@ func takeJob(ctx context.Context, dbFunc func() *gorp.DbMap, store cache.Store,`
`180`	`180`	`wnjri.SubNumber = noderun.SubNumber`
`181`	`181`	`wnjri.Secrets = secrets`
`182`	`182`
`183`		`- params, secretsKeys, errK := workflow.LoadNodeJobRunKeys(p, workflowRun, noderun)`
	`183`	`+ params, secretsKeys, errK := workflow.LoadNodeJobRunKeys(tx, p, workflowRun, noderun)`
`184`	`184`	`if errK != nil {`
`185`	`185`	`return nil, sdk.WrapError(errK, "Cannot load keys")`
`186`	`186`	`}`