Skip to content

Commit 2ee9c5b

Browse files
committed
fix: xo
1 parent 0380156 commit 2ee9c5b

File tree

1 file changed

+5
-15
lines changed

1 file changed

+5
-15
lines changed

test/scenarios/ready.js

Lines changed: 5 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,10 @@
11
const test = require('ava').test;
2-
const AWS = require('aws-sdk');
3-
const PromiseBlue = require('bluebird');
42
const winston = require('winston');
53

64
const StepFunctionWorker = require('../../index.js');
75
const createActivity = require('../utils/create-activity');
86
const cleanUp = require('../utils/clean-up');
97

10-
const stepfunction = new AWS.StepFunctions();
11-
const stepFunctionPromises = PromiseBlue.promisifyAll(stepfunction);
12-
138
const logger = new winston.Logger({
149
transports: [new winston.transports.Console({
1510
level: 'debug'
@@ -36,12 +31,9 @@ const context = {};
3631
const before = createActivity.bind(null, {context, activityName, stateMachineName, workerName});
3732
const after = cleanUp.bind(null, {context, activityName, stateMachineName, workerName});
3833

39-
const sentInput = {foo: 'bar'};
40-
4134
const fn = function (event, callback, heartbeat) {
4235
heartbeat();
4336
setTimeout(() => {
44-
const err = new Error('custom error');
4537
// Assert.equal(event, sentInput);
4638
callback(null, event);
4739
}, 2000);
@@ -51,13 +43,12 @@ test.before(before);
5143

5244
test.serial('Step function Activity Workerhas a ready event', t => {
5345
const activityArn = context.activityArn;
54-
const stateMachineArn = context.stateMachineArn;
5546

5647
return new Promise((resolve, reject) => {
5748
const worker = new StepFunctionWorker({
5849
activityArn,
5950
workerName: workerName + '-fn',
60-
fn: fn,
51+
fn,
6152
logger
6253
});
6354
let ready = false;
@@ -66,14 +57,13 @@ test.serial('Step function Activity Workerhas a ready event', t => {
6657
ready = true;
6758
resolve();
6859
});
69-
70-
setTimeout(function(){
71-
if(!ready){
60+
61+
setTimeout(() => {
62+
if (!ready) {
7263
t.fail();
7364
reject();
7465
}
75-
},1000)
76-
66+
}, 1000);
7767
});
7868
});
7969

0 commit comments

Comments
 (0)