chore: template playbook runsOn

playbook/playbook.go

@@ -12,6 +12,7 @@ import (
 	"github.com/flanksource/duty/context"
 	"github.com/flanksource/duty/models"
 	"github.com/flanksource/duty/types"
+	"github.com/flanksource/gomplate/v3"
 	"github.com/google/uuid"
 	"github.com/samber/lo"
 	"github.com/samber/oops"
@@ -92,10 +93,6 @@ func Run(ctx context.Context, playbook *models.Playbook, req RunParams) (*models
 		AgentID:    req.AgentID,
 	}
 
-	// The run gets its own copy of the spec and uses that throughout its lifecycle.
-	// Any change to the playbook spec while the run is in progress should not affect the run.
-	run.Spec = playbook.Spec
-
 	if ctx.User() != nil {
 		run.CreatedBy = &ctx.User().ID
 	}
@@ -158,6 +155,28 @@ func Run(ctx context.Context, playbook *models.Playbook, req RunParams) (*models
 		return nil, err
 	}
 
+	// The run gets its own copy of the spec and uses that throughout its lifecycle.
+	// Any change to the playbook spec while the run is in progress should not affect the run.
+	var runSpec v1.PlaybookSpec
+	if err := json.Unmarshal(playbook.Spec, &runSpec); err != nil {
+		return nil, ctx.Oops().Wrap(err)
+	}
+	// Template run's spec (runsOn)
+	var runsOn []string
+	for _, specRunOn := range runSpec.RunsOn {
+		output, err := ctx.RunTemplate(gomplate.Template{Template: specRunOn}, templateEnv.AsMap())
+		if err != nil {
+			return nil, ctx.Oops().Wrap(err)
+		}
+		runsOn = append(runsOn, output)
+	}
+	runSpec.RunsOn = runsOn
+
+	run.Spec, err = json.Marshal(runSpec)
+	if err != nil {
+		return nil, ctx.Oops().Wrap(err)
+	}
+
 	if err := savePlaybookRun(ctx, &run); err != nil {
 		return nil, ctx.Oops().Wrapf(err, "failed to create playbook run")
 	}