Merge pull request #600 from shanemcd/write-all-bytes

Ensure all bytes are written to result stream
ansible · Apr 25, 2022 · aead0ba · aead0ba
2 parents 1fd0457 + e7ef918
commit aead0ba
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/workceptor/workceptor.go b/pkg/workceptor/workceptor.go
@@ -564,8 +564,8 @@ func (w *Workceptor) GetResults(ctx context.Context, unitID string, startPos int
 				}
 			}
 			if err == io.EOF {
-				stdoutSize := stdoutSize(unitdir)
-				if IsComplete(unit.Status().State) && stdoutSize >= unit.Status().StdoutSize {
+				unitStatus := unit.Status()
+				if IsComplete(unitStatus.State) && filePos >= unitStatus.StdoutSize {
 					logger.Debug("Stdout complete - closing channel for: %s \n", unitID)
 
 					return