Fix test.

jlewi · Oct 16, 2024 · ca3ed4b · ca3ed4b
1 parent 23218a5
commit ca3ed4b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/app/pkg/analyze/analyzer.go b/app/pkg/analyze/analyzer.go
@@ -136,7 +136,7 @@ func initOffsets(logOffsetsFile string) (*logspb.LogsWaterMark, error) {
 	watermark := &logspb.LogsWaterMark{}
 
 	if err := protojson.Unmarshal(raw, watermark); err != nil {
-		log.Error(err, "Failed to unmarshal watermarks file %s; watermarks will be reinitialized", logOffsetsFile)
+		log.Error(err, "Failed to unmarshal watermarks; watermarks will be reinitialized", "file", logOffsetsFile)
 	}
 	return watermark, nil
 }

diff --git a/app/pkg/analyze/analyzer_test.go b/app/pkg/analyze/analyzer_test.go
@@ -498,8 +498,9 @@ func Test_CombineGenerateEntries(t *testing.T) {
 
 				c.logFunc(zTestLog)
 
-				testLog.Sync()
-
+				if err := testLog.Sync(); err != nil {
+					t.Fatalf("Failed to sync log: %v", err)
+				}
 			}
 
 			for _, logFile := range logFiles {