From 1f7230b694c301d51c2e379d125c2dce104e0116 Mon Sep 17 00:00:00 2001 From: Katrina Rogan Date: Mon, 16 Aug 2021 11:58:28 -0700 Subject: [PATCH] Fix copy paste bug in recovering node exec inputs (#303) Signed-off-by: Katrina Rogan --- pkg/controller/nodes/executor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/controller/nodes/executor.go b/pkg/controller/nodes/executor.go index b8c9e97a8f..d6a146b539 100644 --- a/pkg/controller/nodes/executor.go +++ b/pkg/controller/nodes/executor.go @@ -212,7 +212,7 @@ func (c *nodeExecutor) attemptRecovery(ctx context.Context, nCtx handler.NodeExe } } - if err := c.store.WriteProtobuf(ctx, nCtx.InputReader().GetInputPath(), storage.Options{}, recoveredData.FullInputs); err != nil { + if err := c.store.WriteProtobuf(ctx, nCtx.InputReader().GetInputPath(), storage.Options{}, nodeInputs); err != nil { c.metrics.InputsWriteFailure.Inc(ctx) logger.Errorf(ctx, "Failed to move recovered inputs for Node. Error [%v]. InputsFile [%s]", err, nCtx.InputReader().GetInputPath()) return handler.PhaseInfoUndefined, errors.Wrapf(