refactor: adjust embedding upload frequency

Author: SleepyKFish

cmd/main.go

@@ -167,9 +167,11 @@ func main() {
 	extensionService := service.NewExtensionService(storageManager, syncRepo, scanRepo, workspaceRepo, eventRepo, codebaseEmbeddingRepo, codebaseService, fileScanService, appLogger)
 
 	// Initialize job layer
+	// 定时全量扫工作区
 	fileScanJob := job.NewFileScanJob(fileScanService, storageManager, syncRepo, appLogger, 5*time.Minute)
-	eventProcessorJob := job.NewEventProcessorJob(appLogger, syncRepo, embeddingProcessService, codegraphProcessor, 30*time.Second, storageManager)
-	statusCheckerJob := job.NewStatusCheckerJob(embeddingStatusService, storageManager, syncRepo, appLogger, 20*time.Second)
+	eventProcessorJob := job.NewEventProcessorJob(appLogger, syncRepo, embeddingProcessService, codegraphProcessor, 120*time.Second, storageManager)
+	// 超时处理
+	statusCheckerJob := job.NewStatusCheckerJob(embeddingStatusService, storageManager, syncRepo, appLogger, 80*time.Second)
 	eventCleanerJob := job.NewEventCleanerJob(eventRepo, appLogger)
 	indexCleanJob := job.NewIndexCleanJob(appLogger, indexer, workspaceRepo, storageManager, codebaseEmbeddingRepo, syncRepo, eventRepo)
 	// Initialize handler layer

internal/service/embedding_status.go

@@ -221,6 +221,7 @@ func (sc *embeddingStatusService) checkWorkspaceBuildingStates(workspacePath str
 		}
 
 		// 添加延迟控制请求频率
+		// TODO 加到远程配置
 		time.Sleep(100 * time.Millisecond)
 	}