Skip to content

Commit

Permalink
Fix timeouts from aws-sdk kinesis tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Stephen Belanger committed Dec 28, 2023
1 parent 2127b02 commit 307d4cd
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 6 deletions.
2 changes: 1 addition & 1 deletion packages/datadog-plugin-aws-sdk/test/kinesis.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ describe('Kinesis', () => {
}, (err, res) => {
if (err) return done(err)

helpers.waitForActiveStream(this, kinesis, done)
helpers.waitForActiveStream(kinesis, done)
})
})

Expand Down
8 changes: 3 additions & 5 deletions packages/datadog-plugin-aws-sdk/test/kinesis_helpers.js
Original file line number Diff line number Diff line change
Expand Up @@ -45,17 +45,15 @@ function putTestRecord (kinesis, data, cb) {
}, cb)
}

function waitForActiveStream (mocha, kinesis, cb) {
function waitForActiveStream (kinesis, cb) {
kinesis.describeStream({
StreamName: 'MyStream'
}, (err, data) => {
if (err) {
mocha.timeout(2000)
return waitForActiveStream(mocha, kinesis, cb)
return waitForActiveStream(kinesis, cb)
}
if (data.StreamDescription.StreamStatus !== 'ACTIVE') {
mocha.timeout(2000)
return waitForActiveStream(mocha, kinesis, cb)
return waitForActiveStream(kinesis, cb)
}

cb()
Expand Down

0 comments on commit 307d4cd

Please sign in to comment.