Skip to content

Commit e9623e2

Browse files
committed
internal/rule: fix construction of row repo iterator
Signed-off-by: Miguel Molina <[email protected]>
1 parent 579894a commit e9623e2

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

internal/rule/squashjoins.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -612,10 +612,11 @@ func (t *squashedTable) Resolved() bool {
612612
return true
613613
}
614614
func (t *squashedTable) RowIter(ctx *sql.Context) (sql.RowIter, error) {
615-
return &schemaMapperIter{
616-
gitbase.NewChainableRowRepoIter(ctx, t.iter),
617-
t.schemaMappings,
618-
}, nil
615+
iter, err := gitbase.NewRowRepoIter(ctx, gitbase.NewChainableRowRepoIter(ctx, t.iter))
616+
if err != nil {
617+
return nil, err
618+
}
619+
return &schemaMapperIter{iter, t.schemaMappings}, nil
619620
}
620621
func (t *squashedTable) String() string {
621622
return fmt.Sprintf("SquashedTable(%s)", strings.Join(t.tables, ", "))

0 commit comments

Comments
 (0)