fix(worker): worker export variable were not accessible from next step

engine/worker/internal/run.go

@@ -123,6 +123,14 @@ func (w *CurrentWorker) runJob(ctx context.Context, a *sdk.Action, jobID int64,
 		if nCriticalFailed == 0 || step.AlwaysExecuted {
 			stepResult = w.runAction(ctx, step, jobID, secrets, step.Name)
 
+			// Check if all newVariables are in currentJob.params
+			// variable can be add in w.currentJob.newVariables by worker command export
+			for _, newVariableFromHandler := range w.currentJob.newVariables {
+				if sdk.ParameterFind(w.currentJob.params, newVariableFromHandler.Name) == nil {
+					w.currentJob.params = append(w.currentJob.params, newVariableFromHandler.ToParameter(""))
+				}
+			}
+
 			for _, newVariable := range stepResult.NewVariables {
 				// append the new variable from a step to the following steps
 				w.currentJob.params = append(w.currentJob.params, newVariable.ToParameter("cds.build"))
@@ -259,6 +267,14 @@ func (w *CurrentWorker) runSteps(ctx context.Context, steps []sdk.Action, a sdk.
 			r.Status = sdk.StatusNeverBuilt
 		}
 
+		// Check if all newVariables are in currentJob.params
+		// variable can be add in w.currentJob.newVariables by worker command export
+		for _, newVariableFromHandler := range w.currentJob.newVariables {
+			if sdk.ParameterFind(w.currentJob.params, newVariableFromHandler.Name) == nil {
+				w.currentJob.params = append(w.currentJob.params, newVariableFromHandler.ToParameter(""))
+			}
+		}
+
 		for _, newVariable := range r.NewVariables {
 			// append the new variable from a chile to the following children
 			w.currentJob.params = append(w.currentJob.params, newVariable.ToParameter("cds.build"))

sdk/variable.go

@@ -15,8 +15,12 @@ type Variable struct {
 }
 
 func (v Variable) ToParameter(prefix string) Parameter {
+	name := v.Name
+	if prefix != "" {
+		name = fmt.Sprintf("%s.%s", prefix, v.Name)
+	}
 	return Parameter{
-		Name:  "." + prefix + "." + v.Name,
+		Name:  name,
 		Value: v.Value,
 		Type:  v.Type,
 	}