aboutsummaryrefslogtreecommitdiff
path: root/automation/common/job_group.py
diff options
context:
space:
mode:
Diffstat (limited to 'automation/common/job_group.py')
-rw-r--r--automation/common/job_group.py32
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)