File tree 1 file changed +4
-2
lines changed
1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -844,15 +844,18 @@ describe('Job', () => {
844
844
'lock job' ,
845
845
async _job => {
846
846
runCount ++ ;
847
+ console . log ( 'runCount' , runCount ) ;
847
848
if ( runCount === 1 ) {
848
849
// this should time out
849
850
await new Promise ( longResolve => setTimeout ( longResolve , 1000 ) ) ;
850
851
} else {
852
+ await new Promise ( longResolve => setTimeout ( longResolve , 10 ) ) ;
851
853
resolve ( runCount ) ;
852
854
}
853
855
} ,
854
856
{
855
- lockLifetime : 50
857
+ lockLifetime : 50 ,
858
+ concurrency : 1
856
859
}
857
860
) ;
858
861
} ) ;
@@ -1094,7 +1097,6 @@ describe('Job', () => {
1094
1097
const checkResultsPromise = new Promise ( resolve =>
1095
1098
agenda . on ( 'start:priority' , job => {
1096
1099
results . push ( job . attrs . priority ) ;
1097
- console . log ( 'RESULTS' , results ) ;
1098
1100
if ( results . length !== 3 ) {
1099
1101
return ;
1100
1102
}
You can’t perform that action at this time.
0 commit comments