Convert constant load values to settings
This commit is contained in:
@@ -10,11 +10,7 @@ from clustering.models import Node
|
|||||||
from .models import JobQueue, JobQueueItem
|
from .models import JobQueue, JobQueueItem
|
||||||
from .exceptions import JobQueueNoPendingJobs
|
from .exceptions import JobQueueNoPendingJobs
|
||||||
from .literals import JOB_QUEUE_STATE_STARTED
|
from .literals import JOB_QUEUE_STATE_STARTED
|
||||||
|
from .settings import MAX_CPU_LOAD, MAX_MEMORY_USAGE, NODE_MAX_WORKERS
|
||||||
LOCK_EXPIRE = 10
|
|
||||||
MAX_CPU_LOAD = 60.0
|
|
||||||
MAX_MEMORY_USAGE = 60.0
|
|
||||||
NODE_MAX_WORKERS = len(psutil.cpu_percent(interval=0.1, percpu=True)) # Get CPU/cores count
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
@@ -25,7 +21,7 @@ def job_queue_poll():
|
|||||||
# Poll job queues if node is not overloaded
|
# Poll job queues if node is not overloaded
|
||||||
lock_id = u'job_queue_poll'
|
lock_id = u'job_queue_poll'
|
||||||
try:
|
try:
|
||||||
lock = Lock.acquire_lock(lock_id, LOCK_EXPIRE)
|
lock = Lock.acquire_lock(lock_id)
|
||||||
except LockError:
|
except LockError:
|
||||||
pass
|
pass
|
||||||
else:
|
else:
|
||||||
|
|||||||
Reference in New Issue
Block a user