Revision 919ca415 lib/cli.py
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