zlei6/ragflow
1
0
Fork 0
mirror of https://github.com/infiniflow/ragflow.git synced 2026-09-08 10:14:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat[Go]: resuming transmission from the point of interruption during data source synchronisation (#18176)

Browse Source 
### Summary

As title
This commit is contained in:
Haruko386
2026-08-13 18:38:37 +08:00
committed by GitHub
parent 0784bef5b0
commit 96f7c39753
35 changed files with 2464 additions and 469 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/ragflow_server.go
+5 -8
View File
@@ -633,15 +633,12 @@ func runIngestor(ctx context.Context, cancel context.CancelFunc, args *serverArg
func runSyncer(ctx context.Context, cancel context.CancelFunc, args *serverArgs) error {
globalConfig := server.GetConfig()
syncerConfig := globalConfig.GetSyncerConfig()
fileSyncer := syncer.NewSyncer(syncerConfig.MaxConcurrentSyncs, time.Duration(syncerConfig.SyncInterval)*time.Second)
fileSyncer := syncer.NewSyncer(syncerConfig.MaxConcurrentSyncs)
go func() {
err := fileSyncer.Start()
if err != nil {
common.Error("Failed to initialize file syncer", err)
return
}
}()
if err := fileSyncer.StartContext(ctx); err != nil {
common.Error("Failed to initialize file syncer", err)
return err
}
common.Info("\n _______ __ _____\n" +
" / ____(_) /__ / ___/__ ______ ________ _____\n" +