handle orchestration aborted events

index.js

@@ -54,6 +54,8 @@ function runSequence(gulp) {
 	var callBack = typeof taskSets[taskSets.length - 1] === 'function' ? taskSets.pop() : false;
 	var currentTaskSet;
 
+	var finished;
+
 	if(options().ignoreUndefinedTasks) {
 		// ignore missing tasks
 		taskSets = filterArray(taskSets)
@@ -67,8 +69,11 @@ function runSequence(gulp) {
 	}
 
 	function finish(e) {
+		if (finished) return;
+
 		gulp.removeListener('task_stop', onTaskEnd);
 		gulp.removeListener('task_err', onError);
+		gulp.removeListener('err', onGulpError);
 
 		var error;
 		if(e && e.err) {
@@ -96,6 +101,12 @@ function runSequence(gulp) {
 		}
 	}
 
+	function onGulpError(e) {
+		if (e.message === 'orchestration aborted') {
+			finish(e);
+		}
+	};
+
 	function runNextSet() {
 		if(taskSets.length) {
 			var command = taskSets.shift();
@@ -113,6 +124,7 @@ function runSequence(gulp) {
 
 	gulp.on('task_stop', onTaskEnd);
 	gulp.on('task_err', onError);
+	gulp.on('err', onGulpError);
 
 	runNextSet();
 }

test/main.js

@@ -260,6 +260,40 @@ describe('runSequence', function() {
 
 			called.should.eql(true);
 		})
+
+		it('should pass error if gulp execution halted in second execution', function(done) {
+			const stopTask = gulp.task('stopTask', function() {
+				if (stopTask.shouldStop) {
+					gulp.stop();
+				}
+			});
+
+			stopTask.shouldStop = false;
+
+			var outerTask = gulp.task('outerTask', function(cb) {
+				runSequence('task2', ['stopTask', 'task3'], function(err) {
+					if (stopTask.shouldStop) {
+						try {
+							should(err).be.ok;
+							err.message.should.equal('orchestration aborted');
+						} catch (e) {
+							cb();
+							return done(e);
+						}
+						cb();
+						done();
+					} else {
+						cb();
+					}
+				});
+			});
+
+			gulp.start('outerTask', function() {
+				stopTask.shouldStop = true;
+				task3.shouldPause = true;
+				gulp.start('outerTask');
+			});
+		})
 	});
 
 	describe('Options', function() {
@@ -275,4 +309,4 @@ describe('runSequence', function() {
 		});
 	});
 
-});
+});