This commit is contained in:
Ralf Teusner
2015-11-23 20:25:02 +01:00
5 changed files with 11 additions and 11 deletions

View File

@ -73,7 +73,7 @@ class DockerContainerPool
end
def self.refill
ExecutionEnvironment.where('pool_size > 0').each do |execution_environment|
ExecutionEnvironment.where('pool_size > 0').order(pool_size: :desc).each do |execution_environment|
if config[:refill][:async]
Concurrent::Future.execute { refill_for_execution_environment(execution_environment) }
else
@ -99,7 +99,7 @@ class DockerContainerPool
end
def self.start_refill_task
@refill_task = Concurrent::TimerTask.new(execution_interval: config[:refill][:interval], run_now: false, timeout_interval: config[:refill][:timeout]) { refill }
@refill_task = Concurrent::TimerTask.new(execution_interval: config[:refill][:interval], run_now: true, timeout_interval: config[:refill][:timeout]) { refill }
@refill_task.execute
end
end