Revision 83c046a2 lib/luxi.py
| b/lib/luxi.py | ||
|---|---|---|
| 1 | 1 |
# |
| 2 | 2 |
# |
| 3 | 3 |
|
| 4 |
# Copyright (C) 2006, 2007, 2011 Google Inc. |
|
| 4 |
# Copyright (C) 2006, 2007, 2011, 2012 Google Inc.
|
|
| 5 | 5 |
# |
| 6 | 6 |
# This program is free software; you can redistribute it and/or modify |
| 7 | 7 |
# it under the terms of the GNU General Public License as published by |
| ... | ... | |
| 53 | 53 |
REQ_WAIT_FOR_JOB_CHANGE = "WaitForJobChange" |
| 54 | 54 |
REQ_CANCEL_JOB = "CancelJob" |
| 55 | 55 |
REQ_ARCHIVE_JOB = "ArchiveJob" |
| 56 |
REQ_AUTOARCHIVE_JOBS = "AutoArchiveJobs" |
|
| 56 |
REQ_AUTO_ARCHIVE_JOBS = "AutoArchiveJobs"
|
|
| 57 | 57 |
REQ_QUERY = "Query" |
| 58 | 58 |
REQ_QUERY_FIELDS = "QueryFields" |
| 59 | 59 |
REQ_QUERY_JOBS = "QueryJobs" |
| ... | ... | |
| 64 | 64 |
REQ_QUERY_CONFIG_VALUES = "QueryConfigValues" |
| 65 | 65 |
REQ_QUERY_CLUSTER_INFO = "QueryClusterInfo" |
| 66 | 66 |
REQ_QUERY_TAGS = "QueryTags" |
| 67 |
REQ_QUEUE_SET_DRAIN_FLAG = "SetDrainFlag"
|
|
| 67 |
REQ_SET_DRAIN_FLAG = "SetDrainFlag" |
|
| 68 | 68 |
REQ_SET_WATCHER_PAUSE = "SetWatcherPause" |
| 69 | 69 |
|
| 70 | 70 |
#: List of all LUXI requests |
| 71 | 71 |
REQ_ALL = frozenset([ |
| 72 | 72 |
REQ_ARCHIVE_JOB, |
| 73 |
REQ_AUTOARCHIVE_JOBS, |
|
| 73 |
REQ_AUTO_ARCHIVE_JOBS,
|
|
| 74 | 74 |
REQ_CANCEL_JOB, |
| 75 | 75 |
REQ_QUERY, |
| 76 | 76 |
REQ_QUERY_CLUSTER_INFO, |
| ... | ... | |
| 82 | 82 |
REQ_QUERY_JOBS, |
| 83 | 83 |
REQ_QUERY_NODES, |
| 84 | 84 |
REQ_QUERY_TAGS, |
| 85 |
REQ_QUEUE_SET_DRAIN_FLAG,
|
|
| 85 |
REQ_SET_DRAIN_FLAG, |
|
| 86 | 86 |
REQ_SET_WATCHER_PAUSE, |
| 87 | 87 |
REQ_SUBMIT_JOB, |
| 88 | 88 |
REQ_SUBMIT_MANY_JOBS, |
| ... | ... | |
| 466 | 466 |
version=constants.LUXI_VERSION) |
| 467 | 467 |
|
| 468 | 468 |
def SetQueueDrainFlag(self, drain_flag): |
| 469 |
return self.CallMethod(REQ_QUEUE_SET_DRAIN_FLAG, (drain_flag, ))
|
|
| 469 |
return self.CallMethod(REQ_SET_DRAIN_FLAG, (drain_flag, )) |
|
| 470 | 470 |
|
| 471 | 471 |
def SetWatcherPause(self, until): |
| 472 | 472 |
return self.CallMethod(REQ_SET_WATCHER_PAUSE, (until, )) |
| ... | ... | |
| 489 | 489 |
|
| 490 | 490 |
def AutoArchiveJobs(self, age): |
| 491 | 491 |
timeout = (DEF_RWTO - 1) / 2 |
| 492 |
return self.CallMethod(REQ_AUTOARCHIVE_JOBS, (age, timeout)) |
|
| 492 |
return self.CallMethod(REQ_AUTO_ARCHIVE_JOBS, (age, timeout))
|
|
| 493 | 493 |
|
| 494 | 494 |
def WaitForJobChangeOnce(self, job_id, fields, |
| 495 | 495 |
prev_job_info, prev_log_serial, |
Also available in: Unified diff