@@ -7,8 +7,8 @@ const { setup } = require('./spec_helpers')
77const helpers = require ( './kinesis_helpers' )
88const { rawExpectedSchema } = require ( './kinesis-naming' )
99
10- describe . only ( 'Kinesis' , function ( ) {
11- this . timeout ( 2000 )
10+ describe ( 'Kinesis' , function ( ) {
11+ this . timeout ( 10000 )
1212 setup ( )
1313
1414 withVersions ( 'aws-sdk' , [ 'aws-sdk' , '@aws-sdk/smithy-client' ] , ( version , moduleName ) => {
@@ -225,7 +225,7 @@ describe.only('Kinesis', function () {
225225 expect ( getRecordSpanMeta ) . to . include ( {
226226 'pathway.hash' : expectedConsumerHash
227227 } )
228- } , { timeoutMs : 2000 } ) . then ( done , done )
228+ } , { timeoutMs : 10000 } ) . then ( done , done )
229229
230230 helpers . putTestRecord ( kinesis , streamNameDSM , helpers . dataBuffer , ( err , data ) => {
231231 if ( err ) return done ( err )
@@ -285,10 +285,10 @@ describe.only('Kinesis', function () {
285285 statsPointsReceived += statsBuckets . Stats . length
286286 } )
287287 }
288- } , { timeoutMs : 2000 } )
288+ } , { timeoutMs : 10000 } )
289289 expect ( statsPointsReceived ) . to . be . at . least ( 2 )
290290 expect ( agent . dsmStatsExist ( agent , expectedConsumerHash ) ) . to . equal ( true )
291- } , { timeoutMs : 2000 } ) . then ( done , done )
291+ } , { timeoutMs : 10000 } ) . then ( done , done )
292292
293293 helpers . putTestRecord ( kinesis , streamNameDSM , helpers . dataBuffer , ( err , data ) => {
294294 if ( err ) return done ( err )
@@ -309,10 +309,10 @@ describe.only('Kinesis', function () {
309309 statsPointsReceived += statsBuckets . Stats . length
310310 } )
311311 }
312- } , { timeoutMs : 2000 } )
312+ } , { timeoutMs : 10000 } )
313313 expect ( statsPointsReceived ) . to . equal ( 1 )
314314 expect ( agent . dsmStatsExistWithParentHash ( agent , '0' ) ) . to . equal ( true )
315- } , { timeoutMs : 2000 } ) . then ( done , done )
315+ } , { timeoutMs : 10000 } ) . then ( done , done )
316316
317317 agent . reload ( 'aws-sdk' , { kinesis : { dsmEnabled : false } } , { dsmEnabled : false } )
318318 helpers . putTestRecord ( kinesis , streamNameDSM , helpers . dataBuffer , ( err , data ) => {
@@ -331,7 +331,7 @@ describe.only('Kinesis', function () {
331331 let now = Date . now ( )
332332 nowStub = sinon . stub ( Date , 'now' )
333333 nowStub . callsFake ( ( ) => {
334- now += 200000
334+ now += 1000000
335335 return now
336336 } )
337337
@@ -347,7 +347,7 @@ describe.only('Kinesis', function () {
347347 } )
348348 expect ( statsPointsReceived ) . to . be . at . least ( 3 )
349349 expect ( agent . dsmStatsExist ( agent , expectedProducerHash ) ) . to . equal ( true )
350- } , { timeoutMs : 2000 } ) . then ( done , done )
350+ } , { timeoutMs : 10000 } ) . then ( done , done )
351351
352352 helpers . putTestRecords ( kinesis , streamNameDSM , ( err , data ) => {
353353 // Swallow the error as it doesn't matter for this test.
0 commit comments