Index: impl/prod/raw_datastore.go |
diff --git a/impl/prod/raw_datastore.go b/impl/prod/raw_datastore.go |
index 2353818040022f93afbc61bbd8c08c7c02a6d425..e58d3662051b101122ca03641509030b605498ba 100644 |
--- a/impl/prod/raw_datastore.go |
+++ b/impl/prod/raw_datastore.go |
@@ -217,9 +217,6 @@ func (d rdsImpl) Run(fq *ds.FinalizedQuery, cb ds.RawRunCB) error { |
return err |
} |
if err := cb(dsR2F(k), tf.pm, cfunc); err != nil { |
- if err == ds.Stop { |
- return nil |
- } |
return err |
} |
} |