Commit 49e2f8ef authored by Thomas Phil's avatar Thomas Phil

RM-55 scheduler optimizations

parent d1366ed9
......@@ -17,8 +17,6 @@ class RunResourceManager(Command):
schedulerService = SchedulerDomain.schedulerService()
commandFactory = SchedulerDomain.commandFactory()
#CloudDomain.cloudService().start_reactor() # enable salt reactor
command_bus = schedulerService.getCommandBus()
run_enqueued_jobs_command = commandFactory.newRunEnqueuedJobs()
check_scaling_command = commandFactory.newCheckScaling()
......@@ -32,6 +30,8 @@ class RunResourceManager(Command):
if hasattr(strongr.core.Core.config(), 'celery'): # don't load celery if it's not configured
CloudDomain.cloudService().start_reactor() # salt reactor really shouldn't be initialised here, it's not coupled to celery being configured or not
celery = Celery('strongr', broker=strongr.core.Core.config().celery.broker, backend=strongr.core.Core.config().celery.backend)
remotable_commands = strongr.core.Core.config().celery.remotable_commands.as_dict()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment