diff --git a/scheduler/job/job.go b/scheduler/job/job.go index 8daf7b529..74dc2e41a 100644 --- a/scheduler/job/job.go +++ b/scheduler/job/job.go @@ -185,8 +185,10 @@ func (j *job) preheat(ctx context.Context, req string) error { // Trigger seed peer download seeds. taskID := idgen.TaskIDV1(preheat.URL, urlMeta) log := logger.WithTask(taskID, preheat.URL) - log.Infof("preheat %s headers: %#v, tag: %s, range: %s, filter: %s, digest: %s", - preheat.URL, filterHeaders(urlMeta.Header, log.IsDebug()), urlMeta.Tag, urlMeta.Range, urlMeta.Filter, urlMeta.Digest) + log.Infof("preheat %s tag: %s, range: %s, filter: %s, digest: %s", + preheat.URL, urlMeta.Tag, urlMeta.Range, urlMeta.Filter, urlMeta.Digest) + log.Debugf("preheat %s headers: %#v", preheat.URL, urlMeta.Header) + stream, err := j.resource.SeedPeer().Client().ObtainSeeds(ctx, &cdnsystemv1.SeedRequest{ TaskId: taskID, Url: preheat.URL, @@ -227,14 +229,3 @@ func (j *job) syncPeers() (string, error) { return internaljob.MarshalResponse(hosts) } - -// filterHeaders filters Authorization header if debugging is not enabled -func filterHeaders(urlHeader map[string]string, isDebug bool) map[string]string { - filteredHeaders := make(map[string]string) - for k, v := range urlHeader { - if isDebug || k != headers.Authorization { - filteredHeaders[k] = v - } - } - return filteredHeaders -}