527
ctx context.Context,
528
filter sqlplugin.HistoryScheduledTasksRangeFilter,
529
>
) ([]sqlplugin.HistoryScheduledTasksRow, error) {
execution.go
530
>
var rows []sqlplugin.HistoryScheduledTasksRow
531
>
filter.InclusiveMinVisibilityTimestamp = pdb.converter.ToPostgreSQLDateTime(filter.InclusiveMinVisibilityTimestamp)
532
>
filter.ExclusiveMaxVisibilityTimestamp = pdb.converter.ToPostgreSQLDateTime(filter.ExclusiveMaxVisibilityTimestamp)
533
>
if err := pdb.SelectContext(ctx,
534
>
&rows,
535
>
getHistoryScheduledTasksQuery,
536
>
filter.ShardID,
537
>
filter.CategoryID,
538
>
filter.InclusiveMinVisibilityTimestamp,
539
>
filter.InclusiveMinTaskID,
540
>
filter.InclusiveMinVisibilityTimestamp,
541
>
filter.ExclusiveMaxVisibilityTimestamp,
542
>
filter.PageSize,
543
>
); err != nil {
544
return nil, err
545
}
547
>
rows[i].VisibilityTimestamp = pdb.converter.ToPostgreSQLDateTime(rows[i].VisibilityTimestamp)
548
>
}
549
>
return rows, nil
550
}
551