diff --git a/pkg/sql/type_change.go b/pkg/sql/type_change.go index 0eaa98cae489..b1cbcddc000b 100644 --- a/pkg/sql/type_change.go +++ b/pkg/sql/type_change.go @@ -370,7 +370,9 @@ func (t *typeSchemaChanger) exec(ctx context.Context) error { return err } if fn := t.execCfg.TypeSchemaChangerTestingKnobs.RunBeforeMultiRegionUpdates; fn != nil { - return fn() + if err := fn(); err != nil { + return err + } } repartitionedTables, err = performMultiRegionFinalization( ctx,