Commit 2d537169 authored by Thomas Phil's avatar Thomas Phil

debugging mockcloud

parent 34e27ca6
......@@ -18,9 +18,9 @@ import strongr.core
class RunJobHandler(AbstractRunJobHandler):
def __call__(self, command):
thread = threading.Thread(target=self._run, args=(command,)) # run in separate thread so it doesn't block strongr
thread.start()
#self._run(command)
#thread = threading.Thread(target=self._run, args=(command,)) # run in separate thread so it doesn't block strongr
#thread.start()
self._run(command)
def _run(self, command):
inter_domain_event_factory = Gateways.inter_domain_event_factory()
......
......@@ -16,4 +16,3 @@ class StartJobOnVmHandler:
cloudCommandFactory = strongr.core.domain.clouddomain.CloudDomain.commandFactory()
cloudCommandBus.handle(cloudCommandFactory.newRunJob(host=command.vm_id, image=job.image, script=job.script.splitlines(), job_id=job.job_id, scratch=job.scratch, cores=job.cores, memory=job.ram))
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