Revision 5c735209 lib/luxi.py

b/lib/luxi.py
290 290
    return self.CallMethod(REQ_ARCHIVE_JOB, job_id)
291 291

  
292 292
  def WaitForJobChange(self, job_id, fields, prev_job_info, prev_log_serial):
293
    return self.CallMethod(REQ_WAIT_FOR_JOB_CHANGE,
294
                           (job_id, fields, prev_job_info, prev_log_serial))
293
    timeout = (DEF_RWTO - 1) / 2
294
    while True:
295
      result = self.CallMethod(REQ_WAIT_FOR_JOB_CHANGE,
296
                               (job_id, fields, prev_job_info,
297
                                prev_log_serial, timeout))
298
      if result != constants.JOB_NOTCHANGED:
299
        break
300
    return result
295 301

  
296 302
  def QueryJobs(self, job_ids, fields):
297 303
    return self.CallMethod(REQ_QUERY_JOBS, (job_ids, fields))

Also available in: Unified diff