Skip to content
This repository was archived by the owner on Oct 9, 2023. It is now read-only.

Commit 8a2f8ca

Browse files
authored
only initializing maptask if there is no failure (#352)
Signed-off-by: Daniel Rammer <[email protected]>
1 parent 7bb490f commit 8a2f8ca

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

go/tasks/plugins/array/k8s/executor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ func (e Executor) Handle(ctx context.Context, tCtx core.TaskExecutionContext) (c
8989
nextState, err = array.DetermineDiscoverability(ctx, tCtx, pluginConfig.MaxArrayJobSize, pluginState)
9090

9191
nextPhase, _ := nextState.GetPhase()
92-
if err == nil && nextPhase != arrayCore.PhaseStart {
92+
if err == nil && nextPhase != arrayCore.PhaseStart && nextPhase != arrayCore.PhasePermanentFailure {
9393
// we wait to transition out of PhaseStart to InitializeExternalResources because then the array
9494
// job configuration has then been validated and all of the metadata necessary to report subtask
9595
// status (ie. cache hit / etc) is available.

0 commit comments

Comments
 (0)