3
3
* Use of this source code is governed by a license that
4
4
* can be found in the LICENSE file.
5
5
*/
6
- var vizion = require ( 'vizion' ) ;
7
- var cst = require ( '../constants.js' ) ;
8
- var eachLimit = require ( 'async/eachLimit' ) ;
9
- var debug = require ( 'debug' ) ( 'pm2:worker' ) ;
10
- var domain = require ( 'domain' ) ;
11
- const scheduleJob = require ( 'node-schedule' ) . scheduleJob ;
6
+ const vizion = require ( 'vizion' ) ;
7
+ const eachLimit = require ( 'async/eachLimit' ) ;
8
+ const debug = require ( 'debug' ) ( 'pm2:worker' ) ;
9
+ const domain = require ( 'domain' ) ;
10
+ const Cron = require ( 'croner' ) ;
11
+ const pkg = require ( '../package.json' ) ;
12
+
13
+ var cst = require ( '../constants.js' ) ;
12
14
var vCheck = require ( './VersionCheck.js' )
13
- var pkg = require ( '../package.json' )
14
15
15
16
module . exports = function ( God ) {
16
17
var timer = null ;
@@ -34,7 +35,7 @@ module.exports = function(God) {
34
35
var pm_id = pm2_env . pm_id
35
36
console . log ( '[PM2][WORKER] Registering a cron job on:' , pm_id ) ;
36
37
37
- var job = scheduleJob ( pm2_env . cron_restart , function ( ) {
38
+ var job = Cron ( pm2_env . cron_restart , function ( ) {
38
39
God . restartProcessId ( { id : pm_id } , function ( err , data ) {
39
40
if ( err )
40
41
console . error ( err . stack || err ) ;
@@ -56,7 +57,7 @@ module.exports = function(God) {
56
57
var job = God . CronJobs . get ( God . getCronID ( id ) ) ;
57
58
58
59
if ( job )
59
- job . cancel ( ) ;
60
+ job . stop ( ) ;
60
61
61
62
God . CronJobs . delete ( God . getCronID ( id ) ) ;
62
63
} ;
0 commit comments