Merge pull request ZJONSSON#39 from jeffbski/improve-transform-error

improve transform error message
alietors · Apr 20, 2020 · 94f8592 · 94f8592
2 parents 2fa6e8b + 71110a4
commit 94f8592
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/lib/writer.js b/lib/writer.js
@@ -299,8 +299,14 @@ class ParquetTransformer extends stream.Transform {
 
   _transform(row, encoding, callback) {
     if (row) {
-      this.writer.appendRow(row)
-        .then(d => callback(null,d), callback);
+      this.writer.appendRow(row).then(
+        data => callback(null, data),
+        err => {
+          const fullErr = new Error(`Error transforming to parquet: ${err.toString()} row:${JSON.stringify(row)}`);
+          fullErr.origErr = err;
+          callback(fullErr);
+        }
+      );
     } else {
       callback();
     }