X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/d2efca1759c9e104f67d1caf85c8e62ff06807bd..cd6d6f1f15bc1452a09c16b1a3524b5b289c6100:/services/nodemanager/arvnodeman/jobqueue.py diff --git a/services/nodemanager/arvnodeman/jobqueue.py b/services/nodemanager/arvnodeman/jobqueue.py index db578e01fe..1020b4a80c 100644 --- a/services/nodemanager/arvnodeman/jobqueue.py +++ b/services/nodemanager/arvnodeman/jobqueue.py @@ -7,7 +7,7 @@ from __future__ import absolute_import, print_function import logging import re -import subprocess +import subprocess32 as subprocess import arvados.util @@ -38,7 +38,7 @@ class ServerCalculator(object): self.cores = 0 self.bandwidth = 0 self.price = 9999999 - self.preemptable = False + self.preemptible = False self.extra = {} def meets_constraints(self, **kwargs): @@ -58,7 +58,7 @@ class ServerCalculator(object): self.disk = 0 self.scratch = self.disk * 1000 self.ram = int(self.ram * node_mem_scaling) - self.preemptable = False + self.preemptible = False for name, override in kwargs.iteritems(): if name == 'instance_type': continue if not hasattr(self, name): @@ -139,7 +139,7 @@ class ServerCalculator(object): for s in self.cloud_sizes: if s.id == sizeid: return s - return InvalidCloudSize() + return self.InvalidCloudSize() class JobQueueMonitorActor(clientactor.RemotePollLoopActor): @@ -248,5 +248,5 @@ class JobQueueMonitorActor(clientactor.RemotePollLoopActor): job_uuid, error) self._logger.debug("Calculated wishlist: %s", - ', '.join(s.name for s in server_list) or "(empty)") + ', '.join(s.id for s in server_list) or "(empty)") return super(JobQueueMonitorActor, self)._got_response(server_list)