@@ -8,7 +8,7 @@ var cst = require('../constants.js');
88var eachLimit = require ( 'async/eachLimit' ) ;
99var debug = require ( 'debug' ) ( 'pm2:worker' ) ;
1010var domain = require ( 'domain' ) ;
11- var cronJob = require ( 'cron ' ) . CronJob
11+ const scheduleJob = require ( 'node-schedule ' ) . scheduleJob ;
1212var vCheck = require ( './VersionCheck.js' )
1313var pkg = require ( '../package.json' )
1414
@@ -34,19 +34,14 @@ module.exports = function(God) {
3434 var pm_id = pm2_env . pm_id
3535 console . log ( '[PM2][WORKER] Registering a cron job on:' , pm_id ) ;
3636
37- var job = new cronJob ( {
38- cronTime : pm2_env . cron_restart ,
39- onTick : function ( ) {
40- God . restartProcessId ( { id : pm_id } , function ( err , data ) {
41- if ( err )
42- console . error ( err . stack || err ) ;
43- return ;
44- } ) ;
45- } ,
46- start : false
37+ var job = scheduleJob ( pm2_env . cron_restart , function ( ) {
38+ God . restartProcessId ( { id : pm_id } , function ( err , data ) {
39+ if ( err )
40+ console . error ( err . stack || err ) ;
41+ return ;
42+ } ) ;
4743 } ) ;
4844
49- job . start ( ) ;
5045 God . CronJobs . set ( God . getCronID ( pm_id ) , job ) ;
5146 }
5247
@@ -59,7 +54,7 @@ module.exports = function(God) {
5954 return ;
6055 console . log ( '[PM2] Deregistering a cron job on:' , id ) ;
6156 var job = God . CronJobs . get ( God . getCronID ( id ) ) ;
62- job . stop ( ) ;
57+ job . cancel ( ) ;
6358 God . CronJobs . delete ( God . getCronID ( id ) ) ;
6459 } ;
6560
0 commit comments