Skip to content

Commit a2f278c

Browse files
authored
Merge pull request #128 from ceph/run-priority
Run: Add 'priority' to returned fields
2 parents 1e8da59 + fb5bcff commit a2f278c

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

paddles/models/runs.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -167,6 +167,7 @@ def __json__(self):
167167
suite=self.suite,
168168
machine_type=self.machine_type,
169169
sha1=results['sha1'],
170+
priority=self.priority,
170171
)
171172

172173
@classmethod
@@ -210,6 +211,11 @@ def _updated(self):
210211
def href(self):
211212
return "%s/runs/%s/" % (conf.address, self.name),
212213

214+
@property
215+
def priority(self):
216+
if self.jobs.count():
217+
return self.jobs[0].priority
218+
213219
def get_results(self):
214220
jobs_status = [value[0] for value in self.jobs.values(Job.status)]
215221
queued = jobs_status.count('queued')

paddles/tests/models/test_runs.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -242,3 +242,9 @@ def test_run_results(self):
242242
Job(dict(job_id=70+i, id=int(70+i) ,status=status), new_run)
243243
stats_out[status] = count
244244
assert new_run.get_results() == stats_in
245+
246+
def test_run_priority(self):
247+
run_name = "run_priority"
248+
new_run = Run(run_name)
249+
Job(dict(job_id=1, id=1, status='queued', priority=99), new_run)
250+
assert new_run.priority == 99

0 commit comments

Comments
 (0)