Skip to content

Commit d0b3182

Browse files
authored
fix: db timeafter adjust (#7314)
1 parent ddedcac commit d0b3182

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

backend/helpers/pluginhelper/api/api_collector_with_state.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,12 @@ func NewStatefulApiCollector(args RawDataSubTaskArgs) (*ApiCollectorStateManager
135135

136136
currentTime := time.Now()
137137
oldState.LatestSuccessStart = &currentTime
138-
oldState.TimeAfter = syncPolicy.TimeAfter
138+
if syncPolicy != nil {
139+
oldState.TimeAfter = syncPolicy.TimeAfter
140+
if syncPolicy.TimeAfter != nil && oldTimeAfter != nil && (oldTimeAfter).Before(*syncPolicy.TimeAfter) && !syncPolicy.FullSync {
141+
oldState.TimeAfter = oldTimeAfter
142+
}
143+
}
139144

140145
return &ApiCollectorStateManager{
141146
RawDataSubTaskArgs: args,

0 commit comments

Comments
 (0)