fix: travis

Author: piercus

lib/worker.js

@@ -1,7 +1,7 @@
 const EventEmitter = require('events').EventEmitter;
 const util = require('util');
 const AWS = require('aws-sdk');
-var parser = require('aws-arn-parser');
+const parser = require('aws-arn-parser');
 
 const Pooler = require('./pooler.js');
 const replaceError = require('./replace-error.js');
@@ -29,15 +29,7 @@ function Worker(options) {
 	this.autoStart = typeof (options.autoStart) === 'boolean' ? options.autoStart : true;
 
 	if (!options.activityArn) {
-		throw(new Error('activityArn is mandatory inside Worker'));
-		return;
-	}
-	
-	const {region} = parser(options.activityArn);
-	
-	if(this.stepfunction.config.region !== region){
-		throw(new Error(`activity ARN region (${region}) should match with AWS Region (${this.stepfunction.config.region})`));
-		return;
+		throw (new Error('activityArn is mandatory inside Worker'));
 	}
 
 	this.concurrency = typeof (options.concurrency) === 'number' ? options.concurrency : 1;
@@ -57,6 +49,12 @@ function Worker(options) {
 		throw (new TypeError('worker does not define any function'));
 	}
 
+	const {region} = parser(options.activityArn);
+
+	if (typeof (region) === 'string' && (this.stepfunction.config.region !== region)) {
+		throw (new Error(`activity ARN region (${region}) should match with AWS Region (${this.stepfunction.config.region})`));
+	}
+
 	if (this.autoStart) {
 		setImmediate(() => {
 			this.start(() => {