188
}
189
191
>
shardID := rand.Int31()
192
>
timestamp := s.now()
193
>
taskID := int64(1)
194
>
195
>
filter := sqlplugin.TimerTasksFilter{
196
>
ShardID: shardID,
197
>
VisibilityTimestamp: timestamp,
198
>
TaskID: taskID,
199
>
}
200
>
result, err := s.store.DeleteFromTimerTasks(newExecutionContext(), filter)
201
>
s.NoError(err)
202
>
rowsAffected, err := result.RowsAffected()
203
>
s.NoError(err)
204
>
s.Equal(0, int(rowsAffected))
205
>
206
>
rangeFilter := sqlplugin.TimerTasksRangeFilter{
207
>
ShardID: shardID,
208
>
InclusiveMinTaskID: taskID,
209
>
InclusiveMinVisibilityTimestamp: timestamp,
210
>
ExclusiveMaxVisibilityTimestamp: timestamp.Add(common.ScheduledTaskMinPrecision),
211
>
PageSize: 1,
212
>
}
213
>
rows, err := s.store.RangeSelectFromTimerTasks(newExecutionContext(), rangeFilter)
214
>
s.NoError(err)
215
>
for index := range rows {
216
rows[index].ShardID = shardID
217
}
219
}
220