diff --git a/internal/ingest/victoria.go b/internal/ingest/victoria.go index cafe2fe4..05af9d2f 100644 --- a/internal/ingest/victoria.go +++ b/internal/ingest/victoria.go @@ -101,7 +101,9 @@ func (v *VictoriaIngestor) Start(ctx context.Context) error { } for _, c := range containers { - go v.streamLogs(ctx, c) + if c.State == "running" { + go v.streamLogs(ctx, c) + } } <-ctx.Done()