Skip to content

Commit 872fd75

Browse files
committed
Stil show err about consumer has finished
1 parent b36e7db commit 872fd75

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

lib/logstream/logstream.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -808,6 +808,11 @@ func (g *ContainerLogConsumer) Accept(l tc.Log) {
808808

809809
if g.IsStopped() {
810810
// if the consumer is stopped, we don't want to accept any more logs
811+
g.ls.log.Error().
812+
Str("Test", g.ls.testName).
813+
Str("Container", g.name).
814+
Str("Log", string(l.Content)).
815+
Msg("Consumer has finished, but you are still trying to accept logs. This should never happen")
811816
return
812817
}
813818

0 commit comments

Comments
 (0)