diff --git a/src/storage/filesystem.js b/src/storage/filesystem.js
index 70005326b..edab7beec 100644
--- a/src/storage/filesystem.js
+++ b/src/storage/filesystem.js
@@ -68,18 +68,22 @@ function backup(apiConfig, backupId, source, callback) {
 
         pack.on('error', function (error) {
             console.error('[%s] backup: tar stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         gzip.on('error', function (error) {
             console.error('[%s] backup: gzip stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         encrypt.on('error', function (error) {
             console.error('[%s] backup: encrypt stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         fileStream.on('error', function (error) {
             console.error('[%s] backup: out stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         fileStream.on('close', function () {
diff --git a/src/storage/s3.js b/src/storage/s3.js
index ef3f5cecc..93def6b14 100644
--- a/src/storage/s3.js
+++ b/src/storage/s3.js
@@ -91,14 +91,17 @@ function backup(apiConfig, backupId, source, callback) {
 
         pack.on('error', function (error) {
             console.error('[%s] backup: tar stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         gzip.on('error', function (error) {
             console.error('[%s] backup: gzip stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         encrypt.on('error', function (error) {
             console.error('[%s] backup: encrypt stream error.', backupId, error);
+            callback(new BackupsError(BackupsError.INTERNAL_ERROR, error));
         });
 
         pack.pipe(gzip).pipe(encrypt);