From ff7bd80c0eab09897bd645814c696097ee625a90 Mon Sep 17 00:00:00 2001 From: Andy Arthur Date: Thu, 24 Jun 2021 16:39:16 -0700 Subject: [PATCH] actual fix --- go/store/datas/puller.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/go/store/datas/puller.go b/go/store/datas/puller.go index d9cc86c981..5ffd96b733 100644 --- a/go/store/datas/puller.go +++ b/go/store/datas/puller.go @@ -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}