655
ctx context.Context,
656
filter sqlplugin.TimerTasksRangeFilter,
658
>
var rows []sqlplugin.TimerTasksRow
659
>
filter.InclusiveMinVisibilityTimestamp = pdb.converter.ToPostgreSQLDateTime(filter.InclusiveMinVisibilityTimestamp)
660
>
filter.ExclusiveMaxVisibilityTimestamp = pdb.converter.ToPostgreSQLDateTime(filter.ExclusiveMaxVisibilityTimestamp)
661
>
err := pdb.SelectContext(ctx,
662
>
&rows,
663
>
getTimerTasksQuery,
664
>
filter.ShardID,
665
>
filter.InclusiveMinVisibilityTimestamp,
666
>
filter.InclusiveMinTaskID,
667
>
filter.InclusiveMinVisibilityTimestamp,
668
>
filter.ExclusiveMaxVisibilityTimestamp,
669
>
filter.PageSize,
670
>
)
671
>
if err != nil {
672
return nil, err
673
}
675
rows[i].VisibilityTimestamp = pdb.converter.FromPostgreSQLDateTime(rows[i].VisibilityTimestamp)
676
}
678
}
679