actual fix

This commit is contained in:
Andy Arthur
2021-06-24 16:39:16 -07:00
parent 8d668547c5
commit ff7bd80c0e

View File

@@ -304,6 +304,9 @@ func (p *Puller) Pull(ctx context.Context) error {
}
}
}
if ae.IsSet() {
return ae.Get()
}
if p.wr.Size() > 0 {
completedTables <- FilledWriters{p.wr}