@@ -61,10 +61,10 @@ concurrencies.forEach(function(concurrency) {
6161 function hydrateAndCheck ( cb ) {
6262 hydrate ( task , function ( err , changes ) {
6363 // Reuse existing process during progress
64- changes . metadata . nodeCount . should . eql ( nodeProccessesAtStart ) ;
64+ changes . metadata . nodeCount . should . eql ( parseInt ( nodeProccessesAtStart ) ) ;
6565 shellExec ( 'ps aux | grep "[n]ode" -c' , function ( err , stdout ) {
6666 // keep process open after use
67- parseInt ( stdout ) . should . be . eql ( nodeProccessesAtStart ) ;
67+ parseInt ( stdout ) . should . be . eql ( parseInt ( nodeProccessesAtStart ) ) ;
6868 cb ( err ) ;
6969 } ) ;
7070 } ) ;
@@ -109,7 +109,7 @@ concurrencies.forEach(function(concurrency) {
109109 hydrate ( task , function ( ) {
110110 // +0 process after work
111111 shellExec ( 'ps aux | grep "[n]ode" -c' , function ( err , stdout ) {
112- parseInt ( stdout ) . should . be . eql ( nodeProccessesAtStart ) ;
112+ parseInt ( stdout ) . should . be . eql ( parseInt ( nodeProccessesAtStart ) ) ;
113113 cb ( err ) ;
114114 } ) ;
115115 } ) ;
@@ -156,7 +156,7 @@ concurrencies.forEach(function(concurrency) {
156156 hydrate ( task , function ( ) {
157157 // +0 process after work
158158 shellExec ( 'ps aux | grep "[n]ode" -c' , function ( err , stdout ) {
159- parseInt ( stdout ) . should . be . eql ( nodeProccessesAtStart ) ;
159+ parseInt ( stdout ) . should . be . eql ( parseInt ( nodeProccessesAtStart ) ) ;
160160 cb ( err ) ;
161161 } ) ;
162162 } ) ;
0 commit comments