Revision 919ca415
| b/lib/cli.py | ||
|---|---|---|
| 1790 | 1790 |
GetResults() calls. |
| 1791 | 1791 |
|
| 1792 | 1792 |
""" |
| 1793 |
def __init__(self, cl=None, verbose=True, opts=None): |
|
| 1793 |
def __init__(self, cl=None, verbose=True, opts=None, feedback_fn=None):
|
|
| 1794 | 1794 |
self.queue = [] |
| 1795 | 1795 |
if cl is None: |
| 1796 | 1796 |
cl = GetClient() |
| ... | ... | |
| 1798 | 1798 |
self.verbose = verbose |
| 1799 | 1799 |
self.jobs = [] |
| 1800 | 1800 |
self.opts = opts |
| 1801 |
self.feedback_fn = feedback_fn |
|
| 1801 | 1802 |
|
| 1802 | 1803 |
def QueueJob(self, name, *ops): |
| 1803 | 1804 |
"""Record a job for later submit. |
| ... | ... | |
| 1866 | 1867 |
(idx, _, jid, name) = self._ChooseJob() |
| 1867 | 1868 |
ToStdout("Waiting for job %s for %s...", jid, name)
|
| 1868 | 1869 |
try: |
| 1869 |
job_result = PollJob(jid, cl=self.cl) |
|
| 1870 |
job_result = PollJob(jid, cl=self.cl, feedback_fn=self.feedback_fn)
|
|
| 1870 | 1871 |
success = True |
| 1871 | 1872 |
except (errors.GenericError, luxi.ProtocolError), err: |
| 1872 | 1873 |
_, job_result = FormatError(err) |
Also available in: Unified diff