diff --git a/query/stdlib/influxdata/influxdb/to.go b/query/stdlib/influxdata/influxdb/to.go
index 63ee2f6cde..e13f6d8cbe 100644
--- a/query/stdlib/influxdata/influxdb/to.go
+++ b/query/stdlib/influxdata/influxdb/to.go
@@ -589,6 +589,9 @@ func writeTable(t *ToTransformation, tbl flux.Table) error {
 			}
 		}
 		points, err = tsdb.ExplodePoints(*orgID, *bucketID, points)
+		if err != nil {
+			return err
+		}
 		return d.PointsWriter.WritePoints(context.TODO(), points)
 	})
 }