update tests

kurtosis-tech · Nov 7, 2024 · 62ed9da · 62ed9da
1 parent 8d819bb
commit 62ed9da
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 11 deletions.
diff --git a/...s/client_implementations/persistent_volume/persistent_volume_logs_database_client_test.go b/...s/client_implementations/persistent_volume/persistent_volume_logs_database_client_test.go
@@ -721,11 +721,10 @@ func executeStreamCallAndGetReceivedServiceLogLines(
 		case <-time.Tick(testTimeOut):
 			return nil, stacktrace.NewError("Receiving stream logs in the test has reached the '%v' time out", testTimeOut)
 		case streamErr, isChanOpen := <-errChan:
-			if !isChanOpen && len(userServiceLogsByUuidChan) == 0 {
-				shouldReceiveStream = false
-				break
-			}
-			if streamErr == nil && !isChanOpen {
+			if !isChanOpen {
+				if len(userServiceLogsByUuidChan) == 0 {
+					shouldReceiveStream = false
+				}
 				break
 			}
 			return nil, stacktrace.Propagate(streamErr, "Receiving streaming error.")

diff --git a/engine/server/engine/centralized_logs/logline/logline_sender.go b/engine/server/engine/centralized_logs/logline/logline_sender.go
@@ -6,7 +6,7 @@ import (
 )
 
 const (
-	batchLogsAmount    = 2
+	batchLogsAmount    = 1
 	logsChanBufferSize = 300
 )
 
@@ -63,8 +63,3 @@ func (sender *LogLineSender) Flush() {
 		sender.logLineBuffer[serviceUuid] = []LogLine{}
 	}
 }
-
-func (sender *LogLineSender) Close() {
-	sender.Flush()
-	close(sender.logsChan)
-}