Skip to content

Commit

Permalink
support-deploywf
Browse files Browse the repository at this point in the history
  • Loading branch information
Samra Belachew committed Oct 24, 2023
1 parent fce4fe8 commit 3a6e5b4
Showing 1 changed file with 17 additions and 1 deletion.
18 changes: 17 additions & 1 deletion server/neptune/gateway/deploy/signaler.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,8 @@ type signaler interface {
const (
Deprecated = "deprecated"
Destroy = "-destroy"
Manifest = "manifest_path"
EnvStep = "env"
)

type WorkflowSignaler struct {
Expand Down Expand Up @@ -52,7 +54,7 @@ func (d *WorkflowSignaler) SignalWithStartWorkflow(ctx context.Context, rootCfg
Root: workflows.Root{
Name: rootCfg.Name,
Plan: workflows.Job{
Steps: d.generateSteps(rootCfg.DeploymentWorkflow.Plan.Steps),
Steps: d.prependPlanEnvSteps(rootCfg),
},
Apply: workflows.Job{
Steps: d.generateSteps(rootCfg.DeploymentWorkflow.Apply.Steps),
Expand Down Expand Up @@ -94,6 +96,20 @@ func BuildDeployWorkflowID(repoName string, rootName string) string {
return fmt.Sprintf("%s||%s", repoName, rootName)
}

func (d *WorkflowSignaler) prependPlanEnvSteps(cfg *valid.MergedProjectCfg) []workflows.Step {
var steps []workflows.Step
if t, ok := cfg.Tags[Manifest]; ok {
//this is a Lyft specific env var
steps = append(steps, workflows.Step{
StepName: EnvStep,
EnvVarName: "MANIFEST_FILEPATH",
EnvVarValue: t,
})
}
steps = append(steps, d.generateSteps(cfg.DeploymentWorkflow.Plan.Steps)...)
return steps
}

func (d *WorkflowSignaler) generateSteps(steps []valid.Step) []workflows.Step {
// NOTE: for deployment workflows, we won't support command level user requests for log level output verbosity
var workflowSteps []workflows.Step
Expand Down

0 comments on commit 3a6e5b4

Please sign in to comment.