Martin Blanchard pushed to branch mablanch/117-job-scheduler-refactoring at BuildGrid / buildgrid
Commits:
-
cbbf09f5
by Martin Blanchard at 2018-10-11T20:01:12Z
1 changed file:
Changes:
... | ... | @@ -83,6 +83,7 @@ class Scheduler: |
83 | 83 |
|
84 | 84 |
def update_job_lease_state(self, job_name, lease_state, lease_status=None, lease_result=None):
|
85 | 85 |
job = self.jobs[job_name]
|
86 |
+ |
|
86 | 87 |
if lease_state != LeaseState.COMPLETED:
|
87 | 88 |
job.update_lease_state(lease_state)
|
88 | 89 |
else:
|
... | ... | @@ -100,6 +101,16 @@ class Scheduler: |
100 | 101 |
def get_job_lease(self, name):
|
101 | 102 |
return self.jobs[name].lease
|
102 | 103 |
|
104 |
+ def cancel_job_operation(self, job_name):
|
|
105 |
+ """"Cancels the underlying operation of a given job.
|
|
106 |
+ |
|
107 |
+ This will also cancel any job's lease that may have been issued.
|
|
108 |
+ |
|
109 |
+ Args:
|
|
110 |
+ job_name (str): name of the job holding the operation to cancel.
|
|
111 |
+ """
|
|
112 |
+ self.jobs[job_name].cancel_operation()
|
|
113 |
+ |
|
103 | 114 |
def create_lease(self):
|
104 | 115 |
if self.queue:
|
105 | 116 |
job = self.queue.popleft()
|