fix: compare time chunks against zero (#235)

go-vela · Nov 8, 2021 · 5679bf2 · 5679bf2
1 parent 9445acf
commit 5679bf2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 8 deletions.
diff --git a/executor/linux/service.go b/executor/linux/service.go
@@ -256,11 +256,8 @@ func (c *client) StreamService(ctx context.Context, ctn *pipeline.Container) err
 					return
 				// channel is not closed
 				default:
-					// get the current size of log data
-					size := len(_log.GetData())
-
 					// update the existing log with the new bytes if there is new data to add
-					if len(logs.Bytes()) > size {
+					if len(logs.Bytes()) > 0 {
 						logger.Trace(logs.String())
 
 						// update the existing log with the new bytes

diff --git a/executor/linux/step.go b/executor/linux/step.go
@@ -305,11 +305,8 @@ func (c *client) StreamStep(ctx context.Context, ctn *pipeline.Container) error
 					return
 				// channel is not closed
 				default:
-					// get the current size of log data
-					size := len(_log.GetData())
-
 					// update the existing log with the new bytes if there is new data to add
-					if len(logs.Bytes()) > size {
+					if len(logs.Bytes()) > 0 {
 						logger.Trace(logs.String())
 
 						// update the existing log with the new bytes