Merge pull request #29 from beclab/feat/extractor

sync key add model name
beclab · Aug 14, 2024 · fa33dd1 · fa33dd1
2 parents 6c7b61d + 121483a
commit fa33dd1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/prerank-stages/recall/main.go b/prerank-stages/recall/main.go
@@ -188,7 +188,7 @@ func main() {
 	source := common.GetAlgorithmSource()
 	startTimestamp := int64(time.Now().UTC().Unix())
 
-	syncKey := common.GetSyncProvider() + common.GetSyncFeedName()
+	syncKey := common.GetSyncProvider() + common.GetSyncFeedName() + "_" + common.GetSyncModelName()
 	lastSyncTimeStr, _ := api.GetRedisConfig(syncKey, "last_sync_time").(string)
 	if lastSyncTimeStr == "" {
 		common.Logger.Info("sync data is not end no execute", zap.String("syncKey:", syncKey))