new schaeduler, thanks Niphlod and Marin
This commit is contained in:
@@ -1 +1 @@
|
|||||||
Version 2.00.0 (2012-08-03 00:55:12) dev
|
Version 2.00.0 (2012-08-03 08:57:50) dev
|
||||||
|
|||||||
@@ -63,6 +63,7 @@ import os
|
|||||||
import time
|
import time
|
||||||
import multiprocessing
|
import multiprocessing
|
||||||
import sys
|
import sys
|
||||||
|
import signal
|
||||||
import cStringIO
|
import cStringIO
|
||||||
import threading
|
import threading
|
||||||
import traceback
|
import traceback
|
||||||
@@ -90,6 +91,7 @@ except:
|
|||||||
from gluon import DAL, Field, IS_NOT_EMPTY, IS_IN_SET, IS_NOT_IN_DB
|
from gluon import DAL, Field, IS_NOT_EMPTY, IS_IN_SET, IS_NOT_IN_DB
|
||||||
from gluon.utils import web2py_uuid
|
from gluon.utils import web2py_uuid
|
||||||
|
|
||||||
|
|
||||||
QUEUED = 'QUEUED'
|
QUEUED = 'QUEUED'
|
||||||
ASSIGNED = 'ASSIGNED'
|
ASSIGNED = 'ASSIGNED'
|
||||||
RUNNING = 'RUNNING'
|
RUNNING = 'RUNNING'
|
||||||
@@ -435,6 +437,7 @@ class Scheduler(MetaScheduler):
|
|||||||
db.commit()
|
db.commit()
|
||||||
|
|
||||||
def loop(self,worker_name=None):
|
def loop(self,worker_name=None):
|
||||||
|
signal.signal(signal.SIGTERM, lambda signum, stack_frame: sys.exit(1))
|
||||||
try:
|
try:
|
||||||
self.start_heartbeats()
|
self.start_heartbeats()
|
||||||
while True and self.have_heartbeat:
|
while True and self.have_heartbeat:
|
||||||
@@ -782,6 +785,7 @@ def main():
|
|||||||
group_names = group_names,
|
group_names = group_names,
|
||||||
heartbeat = options.heartbeat,
|
heartbeat = options.heartbeat,
|
||||||
max_empty_runs = options.max_empty_runs)
|
max_empty_runs = options.max_empty_runs)
|
||||||
|
signal.signal(signal.SIGTERM, lambda signum, stack_frame: sys.exit(1))
|
||||||
print 'starting main worker loop...'
|
print 'starting main worker loop...'
|
||||||
scheduler.loop()
|
scheduler.loop()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user