696
ctx context.Context,
697
filter sqlplugin.TimerTasksRangeFilter,
699
>
filter.InclusiveMinVisibilityTimestamp = pdb.converter.ToPostgreSQLDateTime(filter.InclusiveMinVisibilityTimestamp)
700
>
filter.ExclusiveMaxVisibilityTimestamp = pdb.converter.ToPostgreSQLDateTime(filter.ExclusiveMaxVisibilityTimestamp)
701
>
return pdb.ExecContext(ctx,
702
>
rangeDeleteTimerTaskQuery,
703
>
filter.ShardID,
704
>
filter.InclusiveMinVisibilityTimestamp,
705
>
filter.ExclusiveMaxVisibilityTimestamp,
706
>
)
707
>
}
708
709
// InsertIntoBufferedEvents inserts one or more rows into buffered_events table