writing zero length inputs

Signed-off-by: Daniel Rammer <[email protected]>
flyteorg · Dec 13, 2023 · 5b9a27e · 5b9a27e
1 parent 3f4ba2e
commit 5b9a27e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flytepropeller/pkg/controller/nodes/executor.go b/flytepropeller/pkg/controller/nodes/executor.go
@@ -753,7 +753,7 @@ func (c *nodeExecutor) preExecute(ctx context.Context, dag executors.DAGStructur
 				return handler.PhaseInfoFailure(core.ExecutionError_SYSTEM, "BindingResolutionFailure", err.Error(), nil), nil
 			}
 
-			if nodeInputs != nil && len(nodeInputs.Literals) > 0 {
+			if nodeInputs != nil {
 				inputsFile := v1alpha1.GetInputsFile(dataDir)
 				if err := c.store.WriteProtobuf(ctx, inputsFile, storage.Options{}, nodeInputs); err != nil {
 					c.metrics.InputsWriteFailure.Inc(ctx)