Skip to content

Commit 51ae07a

Browse files
committed
feat(classifier): more nested query cases
1 parent 3b183fe commit 51ae07a

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
@@ -310,7 +310,25 @@ func GetErrorClass(ctx context.Context, err error) (ErrorClass, ErrorInfo) {
310310
}
311311
case 439: // CANNOT_SCHEDULE_TASK
312312
return ErrorRetryRecoverable, chErrorInfo
313-
case chproto.ErrIllegalTypeOfArgument:
313+
case chproto.ErrUnsupportedMethod,
314+
chproto.ErrIllegalColumn,
315+
chproto.ErrDuplicateColumn,
316+
chproto.ErrNotFoundColumnInBlock,
317+
chproto.ErrUnknownIdentifier,
318+
chproto.ErrUnknownFunction,
319+
chproto.ErrBadTypeOfField,
320+
chproto.ErrTooDeepRecursion,
321+
chproto.ErrTypeMismatch,
322+
chproto.ErrCannotConvertType,
323+
chproto.ErrIncompatibleColumns,
324+
chproto.ErrUnexpectedExpression,
325+
chproto.ErrIllegalAggregation,
326+
chproto.ErrNotAnAggregate,
327+
chproto.ErrSizesOfArraysDoesntMatch,
328+
chproto.ErrAliasRequired,
329+
691, // UNKNOWN_ELEMENT_OF_ENUM
330+
chproto.ErrNoCommonType,
331+
chproto.ErrIllegalTypeOfArgument:
314332
var qrepSyncError *exceptions.QRepSyncError
315333
if errors.As(err, &qrepSyncError) {
316334
unexpectedSelectRe, reErr := regexp.Compile(

0 commit comments

Comments
 (0)