diff --git a/pkg/sources/github/github.go b/pkg/sources/github/github.go index b2fc1f271..1a1724275 100644 --- a/pkg/sources/github/github.go +++ b/pkg/sources/github/github.go @@ -105,6 +105,7 @@ func (s *Source) Init(aCtx context.Context, name string, jobID, sourceID int64, s.jobID = jobID s.verify = verify s.jobSem = semaphore.NewWeighted(int64(concurrency)) + s.resumeInfoMutex = &sync.Mutex{} s.httpClient = common.SaneHttpClient()