diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go index 7d60474fbaf8..c334cf8501b4 100644 --- a/pkg/loki/modules.go +++ b/pkg/loki/modules.go @@ -173,7 +173,9 @@ func (t *Loki) initDistributor() (services.Service, error) { return nil, err } - if !t.Cfg.isModuleEnabled(All) { + // Register the distributor to receive Push requests over GRPC + // EXCEPT when running with `-target=all` or `-target=` contains `ingester` + if !t.Cfg.isModuleEnabled(All) && !t.Cfg.isModuleEnabled(Ingester) { logproto.RegisterPusherServer(t.Server.GRPC, t.distributor) }