).WithContext(ctx)
} else {
minTimestamp := p.UnixMilliseconds(request.InclusiveMinTaskKey.FireTime)
mutable_state_task_store.go
maxTimestamp := p.UnixMilliseconds(request.ExclusiveMaxTaskKey.FireTime)
query = d.Session.Query(templateRangeCompleteHistoryScheduledTasksQuery,
request.ShardID,
request.TaskCategory.ID(),
rowTypeHistoryTaskNamespaceID,
rowTypeHistoryTaskWorkflowID,
rowTypeHistoryTaskRunID,
minTimestamp,
maxTimestamp,
).WithContext(ctx)
}
err := query.Exec()