File tree Expand file tree Collapse file tree 1 file changed +1
-5
lines changed
Expand file tree Collapse file tree 1 file changed +1
-5
lines changed Original file line number Diff line number Diff line change @@ -468,6 +468,7 @@ func (m *LogStream) DisconnectContainer(container LogProducingContainer) error {
468468 for _ , consumer := range m .consumers {
469469 if consumer .container .GetContainerID () == container .GetContainerID () {
470470 consumerFound = true
471+ m .log .Info ().Str ("Container" , consumer .name ).Msg ("Stopping consumer" )
471472 if stopErr := consumer .stop (); err != nil {
472473 m .log .Error ().
473474 Err (stopErr ).
@@ -787,11 +788,6 @@ func (g *ContainerLogConsumer) Accept(l tc.Log) {
787788 }
788789
789790 if g .isDone {
790- g .ls .log .Error ().
791- Str ("Test" , g .ls .testName ).
792- Str ("Container" , g .name ).
793- Str ("Log" , string (l .Content )).
794- Msg ("Consumer has finished, but you are still trying to accept logs. This should never happen" )
795791 return
796792 }
797793
You can’t perform that action at this time.
0 commit comments