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