close writer to force sync to disk in rotation tests

observIQ · Feb 18, 2022 · 6a61f82 · 6a61f82
1 parent 08644fc
commit 6a61f82
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/operator/builtin/input/file/rotation_test.go b/operator/builtin/input/file/rotation_test.go
@@ -11,6 +11,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/observiq/nanojack"
 	"github.com/observiq/stanza/entry"
 	"github.com/observiq/stanza/operator/helper"
 	"github.com/observiq/stanza/testutil"
@@ -254,6 +255,9 @@ func (rt rotationTest) run(tc rotationTest, copyTruncate, sequential bool) func(
 			time.Sleep(tc.writeInterval)
 		}
 
+		// Close the logger's writer to force a sync to disk
+		require.NoError(t, logger.Writer().(*nanojack.Logger).Close())
+
 		received := make([]string, 0, tc.totalLines)
 	LOOP:
 		for {