Monorepo for Tangled
0

Configure Feed

Select the types of activity you want to include in your feed.

spindle: increase queue worker & size and remove redundant git sync

Signed-off-by: dawn <dawn@tangled.org>

author
dawn
date (Jul 21, 2026, 12:08 PM +0300) commit 0e430228 parent dc600b74 change-id wuurlpxn
+2 -4
+2 -4
spindle/server.go
··· 197 197 ccfg.Logger = log.SubLogger(logger, "eventconsumer") 198 198 ccfg.ProcessFunc = spindle.processKnotStream 199 199 ccfg.CursorStore = cursorStore 200 + ccfg.WorkerCount = 16 201 + ccfg.QueueSize = 200 200 202 if cfg.Server.Dev { 201 203 ccfg.RetryInterval = 5 * time.Second 202 204 ccfg.MaxRetryInterval = 10 * time.Second ··· 444 446 // NOTE: we are blindly trusting the knot that it will return only repos it own 445 447 repoCloneUri := s.newRepoCloneUrl(src.Host, repoDid) 446 448 repoPath := s.newRepoPath(repoDid) 447 - if err := git.SparseSyncGitRepo(ctx, repoCloneUri, repoPath, event.NewSha); err != nil { 448 - return fmt.Errorf("sync git repo: %w", err) 449 - } 450 - l.Info("synced git repo") 451 449 452 450 triggerRepo, err := s.buildTriggerRepo(ctx, repo) 453 451 if err != nil {