diff --git a/pkg/jobs/gen_check_stmt.go b/pkg/jobs/gen_check_stmt.go index 59a71e24..a36cefd1 100644 --- a/pkg/jobs/gen_check_stmt.go +++ b/pkg/jobs/gen_check_stmt.go @@ -497,7 +497,7 @@ func genMultiplePartitionClusteringRangeQueryMv( StmtCache: &typedef.StmtCache{ Query: builder, Types: typs, - QueryType: typedef.SelectRangeStatementType, + QueryType: typedef.SelectFromMaterializedViewStatementType, }, Values: values, } diff --git a/pkg/typedef/typedef.go b/pkg/typedef/typedef.go index a3472b3c..921cc323 100644 --- a/pkg/typedef/typedef.go +++ b/pkg/typedef/typedef.go @@ -89,7 +89,12 @@ func (s *Stmt) PrettyCQL() string { type StatementType uint8 func (st StatementType) PossibleAsyncOperation() bool { - return st == SelectByIndexStatementType || st == SelectFromMaterializedViewStatementType + switch st { + case SelectByIndexStatementType, SelectFromMaterializedViewStatementType: + return true + default: + return false + } } type Values []interface{}