Skip to content

Commit 597a6d3

Browse files
feat(classifier): more nested query cases (#2921)
Add more cases when "pushing to view" is not present, and instead it could be `select from <destinationTable>`
1 parent d9a00ad commit 597a6d3

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
@@ -337,7 +337,25 @@ func GetErrorClass(ctx context.Context, err error) (ErrorClass, ErrorInfo) {
337337
}
338338
case 439: // CANNOT_SCHEDULE_TASK
339339
return ErrorRetryRecoverable, chErrorInfo
340-
case chproto.ErrIllegalTypeOfArgument:
340+
case chproto.ErrUnsupportedMethod,
341+
chproto.ErrIllegalColumn,
342+
chproto.ErrDuplicateColumn,
343+
chproto.ErrNotFoundColumnInBlock,
344+
chproto.ErrUnknownIdentifier,
345+
chproto.ErrUnknownFunction,
346+
chproto.ErrBadTypeOfField,
347+
chproto.ErrTooDeepRecursion,
348+
chproto.ErrTypeMismatch,
349+
chproto.ErrCannotConvertType,
350+
chproto.ErrIncompatibleColumns,
351+
chproto.ErrUnexpectedExpression,
352+
chproto.ErrIllegalAggregation,
353+
chproto.ErrNotAnAggregate,
354+
chproto.ErrSizesOfArraysDoesntMatch,
355+
chproto.ErrAliasRequired,
356+
691, // UNKNOWN_ELEMENT_OF_ENUM
357+
chproto.ErrNoCommonType,
358+
chproto.ErrIllegalTypeOfArgument:
341359
var qrepSyncError *exceptions.QRepSyncError
342360
if errors.As(err, &qrepSyncError) {
343361
unexpectedSelectRe, reErr := regexp.Compile(

0 commit comments

Comments
 (0)