diff --git a/pkg/profilestore/grpc.go b/pkg/profilestore/grpc.go index 0b4dab84544..8d31c28c009 100644 --- a/pkg/profilestore/grpc.go +++ b/pkg/profilestore/grpc.go @@ -63,7 +63,11 @@ func (s *GRPCForwarder) WriteRaw(ctx context.Context, req *profilestorepb.WriteR // See https://github.com/parca-dev/parca-agent/blob/main/pkg/agent/write_client.go#L28 resp, err := s.client.WriteRaw(ctx, req) if err != nil { - level.Warn(s.logger).Log("msg", "failed to forward profiles", "err", err) + target, ok := ctx.Value("target").(string) + if !ok { + target = "unknown" + } + level.Warn(s.logger).Log("msg", "failed to forward profiles", "target", target, "err", err) } return resp, err } diff --git a/pkg/scrape/scrape.go b/pkg/scrape/scrape.go index c7c1d71bcdb..44f175ca7ff 100644 --- a/pkg/scrape/scrape.go +++ b/pkg/scrape/scrape.go @@ -649,6 +649,8 @@ func processScrapeResp(ctx context.Context, buf *bytes.Buffer, sl *scrapeLoop, p byt = newBuf.Bytes() } + target := sl.target.String() + ctx = context.WithValue(ctx, "target", target) _, err = sl.store.WriteRaw(ctx, &profilepb.WriteRawRequest{ Normalized: sl.normalizedAddresses, Series: []*profilepb.RawProfileSeries{