chore: add plan tests

runatlantis · May 9, 2023 · ec0644b · ec0644b
1 parent be6bea4
commit ec0644b
Show file tree

Hide file tree

Showing 5 changed files with 365 additions and 4 deletions.
diff --git a/server/events/apply_command_runner.go b/server/events/apply_command_runner.go
@@ -161,7 +161,7 @@ func (a *ApplyCommandRunner) Run(ctx *command.Context, cmd *CommentCommand) {
 	var result command.Result
 	if a.isParallelEnabled(projectCmds) {
 		ctx.Log.Info("Running applies in parallel")
-		result = runProjectCmdsParallelGroups(projectCmds, a.prjCmdRunner.Apply, a.parallelPoolSize)
+		result = runProjectCmdsParallelGroups(ctx, projectCmds, a.prjCmdRunner.Apply, a.parallelPoolSize)
 	} else {
 		result = runProjectCmds(projectCmds, a.prjCmdRunner.Apply)
 	}

diff --git a/server/events/apply_command_runner_test.go b/server/events/apply_command_runner_test.go
@@ -262,7 +262,7 @@ func TestApplyCommandRunner_ExecutionOrder(t *testing.T) {
 				"2. dir: `` workspace: ``\n**Apply Error**\n```\nShabang!\n```\n\n---",
 		},
 		{
-			Description: "When first apply succeeds, the second will run",
+			Description: "When first fails succeeds, the second not will run",
 			ProjectContexts: []command.ProjectContext{
 				{
 					ExecutionOrderGroup:        0,

diff --git a/server/events/plan_command_runner.go b/server/events/plan_command_runner.go
@@ -130,7 +130,7 @@ func (p *PlanCommandRunner) runAutoplan(ctx *command.Context) {
 	var result command.Result
 	if p.isParallelEnabled(projectCmds) {
 		ctx.Log.Info("Running plans in parallel")
-		result = runProjectCmdsParallelGroups(projectCmds, p.prjCmdRunner.Plan, p.parallelPoolSize)
+		result = runProjectCmdsParallelGroups(ctx, projectCmds, p.prjCmdRunner.Plan, p.parallelPoolSize)
 	} else {
 		result = runProjectCmds(projectCmds, p.prjCmdRunner.Plan)
 	}
@@ -250,7 +250,7 @@ func (p *PlanCommandRunner) run(ctx *command.Context, cmd *CommentCommand) {
 	var result command.Result
 	if p.isParallelEnabled(projectCmds) {
 		ctx.Log.Info("Running plans in parallel")
-		result = runProjectCmdsParallelGroups(projectCmds, p.prjCmdRunner.Plan, p.parallelPoolSize)
+		result = runProjectCmdsParallelGroups(ctx, projectCmds, p.prjCmdRunner.Plan, p.parallelPoolSize)
 	} else {
 		result = runProjectCmds(projectCmds, p.prjCmdRunner.Plan)
 	}