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}