var query gocql.Query
if request.TaskCategory.Type() == tasks.CategoryTypeImmediate {
query = d.Session.Query(templateRangeCompleteHistoryImmediateTasksQuery,
mutable_state_task_store.go
request.ShardID,
request.TaskCategory.ID(),
rowTypeHistoryTaskNamespaceID,
rowTypeHistoryTaskWorkflowID,
rowTypeHistoryTaskRunID,
defaultVisibilityTimestamp,
request.InclusiveMinTaskKey.TaskID,
request.ExclusiveMaxTaskKey.TaskID,
).WithContext(ctx)
} else {
minTimestamp := p.UnixMilliseconds(request.InclusiveMinTaskKey.FireTime)