Fix payload debug hung job (#1173)

ansible · Oct 17, 2024 · 2e02922 · 2e02922
1 parent 2a415c4
commit 2e02922
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/pkg/workceptor/command.go b/pkg/workceptor/command.go
@@ -126,9 +126,6 @@ func commandRunner(command string, params string, unitdir string) error {
 		}
 		var payload string
 		reader := bufio.NewReader(stdin)
-		if err != nil {
-			return err
-		}
 
 		for {
 			response, err := reader.ReadString('\n')
@@ -144,6 +141,7 @@ func commandRunner(command string, params string, unitdir string) error {
 
 		MainInstance.nc.GetLogger().DebugPayload(payloadDebug, payload, workUnitID, "")
 		io.WriteString(stdinStream, payload)
+		stdinStream.Close()
 	} else {
 		cmd.Stdin = stdin
 	}