fix: db timeafter adjust (#7314)

apache · Apr 12, 2024 · d0b3182 · d0b3182
1 parent ddedcac
commit d0b3182
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/backend/helpers/pluginhelper/api/api_collector_with_state.go b/backend/helpers/pluginhelper/api/api_collector_with_state.go
@@ -135,7 +135,12 @@ func NewStatefulApiCollector(args RawDataSubTaskArgs) (*ApiCollectorStateManager
 
 	currentTime := time.Now()
 	oldState.LatestSuccessStart = &currentTime
-	oldState.TimeAfter = syncPolicy.TimeAfter
+	if syncPolicy != nil {
+		oldState.TimeAfter = syncPolicy.TimeAfter
+		if syncPolicy.TimeAfter != nil && oldTimeAfter != nil && (oldTimeAfter).Before(*syncPolicy.TimeAfter) && !syncPolicy.FullSync {
+			oldState.TimeAfter = oldTimeAfter
+		}
+	}
 
 	return &ApiCollectorStateManager{
 		RawDataSubTaskArgs: args,