Skip to content

Commit 785a3ef

Browse files
committed
feat(classifier): more nested query cases
1 parent 4b45b15 commit 785a3ef

File tree

1 file changed

+19
-1
lines changed

1 file changed

+19
-1
lines changed

flow/alerting/classifier.go

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,25 @@ func GetErrorClass(ctx context.Context, err error) (ErrorClass, ErrorInfo) {
300300
}
301301
case 439: // CANNOT_SCHEDULE_TASK
302302
return ErrorRetryRecoverable, chErrorInfo
303-
case chproto.ErrIllegalTypeOfArgument:
303+
case chproto.ErrUnsupportedMethod,
304+
chproto.ErrIllegalColumn,
305+
chproto.ErrDuplicateColumn,
306+
chproto.ErrNotFoundColumnInBlock,
307+
chproto.ErrUnknownIdentifier,
308+
chproto.ErrUnknownFunction,
309+
chproto.ErrBadTypeOfField,
310+
chproto.ErrTooDeepRecursion,
311+
chproto.ErrTypeMismatch,
312+
chproto.ErrCannotConvertType,
313+
chproto.ErrIncompatibleColumns,
314+
chproto.ErrUnexpectedExpression,
315+
chproto.ErrIllegalAggregation,
316+
chproto.ErrNotAnAggregate,
317+
chproto.ErrSizesOfArraysDoesntMatch,
318+
chproto.ErrAliasRequired,
319+
691, // UNKNOWN_ELEMENT_OF_ENUM
320+
chproto.ErrNoCommonType,
321+
chproto.ErrIllegalTypeOfArgument:
304322
var qrepSyncError *exceptions.QRepSyncError
305323
if errors.As(err, &qrepSyncError) {
306324
unexpectedSelectRe, reErr := regexp.Compile(

0 commit comments

Comments
 (0)