diff options
Diffstat (limited to 'automation/common/job_group.py')
-rw-r--r-- | automation/common/job_group.py | 32 |
1 files changed, 17 insertions, 15 deletions
diff --git a/automation/common/job_group.py b/automation/common/job_group.py index 09321e1a..96912fc1 100644 --- a/automation/common/job_group.py +++ b/automation/common/job_group.py @@ -1,5 +1,3 @@ -#!/usr/bin/python -# # Copyright 2010 Google Inc. All Rights Reserved. # @@ -8,25 +6,30 @@ import os from automation.common.state_machine import BasicStateMachine -STATUS_NOT_EXECUTED = "NOT_EXECUTED" -STATUS_EXECUTING = "EXECUTING" -STATUS_SUCCEEDED = "SUCCEEDED" -STATUS_FAILED = "FAILED" +STATUS_NOT_EXECUTED = 'NOT_EXECUTED' +STATUS_EXECUTING = 'EXECUTING' +STATUS_SUCCEEDED = 'SUCCEEDED' +STATUS_FAILED = 'FAILED' class JobGroupStateMachine(BasicStateMachine): state_machine = { STATUS_NOT_EXECUTED: [STATUS_EXECUTING], - STATUS_EXECUTING: [STATUS_SUCCEEDED, STATUS_FAILED]} + STATUS_EXECUTING: [STATUS_SUCCEEDED, STATUS_FAILED] + } final_states = [STATUS_SUCCEEDED, STATUS_FAILED] class JobGroup(object): - HOMEDIR_PREFIX = os.path.join("/home", getpass.getuser(), "www", "automation") - - def __init__(self, label, jobs=None, cleanup_on_completion=True, - cleanup_on_failure=False, description=""): + HOMEDIR_PREFIX = os.path.join('/home', getpass.getuser(), 'www', 'automation') + + def __init__(self, + label, + jobs=None, + cleanup_on_completion=True, + cleanup_on_failure=False, + description=''): self._state = JobGroupStateMachine(STATUS_NOT_EXECUTED) self.id = 0 self.label = label @@ -49,7 +52,7 @@ class JobGroup(object): @property def home_dir(self): - return os.path.join(self.HOMEDIR_PREFIX, "job-group-%d" % self.id) + return os.path.join(self.HOMEDIR_PREFIX, 'job-group-%d' % self.id) @property def time_submitted(self): @@ -62,9 +65,8 @@ class JobGroup(object): return '{%s: %s}' % (self.__class__.__name__, self.id) def __str__(self): - return "\n".join(["Job-Group:", - "ID: %s" % self.id] + - [str(job) for job in self.jobs]) + return '\n'.join(['Job-Group:', 'ID: %s' % self.id] + [str( + job) for job in self.jobs]) def AddJob(self, job): self.jobs.append(job) |