Revision d9d1e541 lib/luxi.py

b/lib/luxi.py
53 53 
REQ_SUBMIT_JOB = "SubmitJob"
54 54 
REQ_SUBMIT_JOB_TO_DRAINED_QUEUE = "SubmitJobToDrainedQueue"
55 55 
REQ_SUBMIT_MANY_JOBS = "SubmitManyJobs"
56 
REQ_PICKUP_JOB = "PickupJob"
56 57 
REQ_WAIT_FOR_JOB_CHANGE = "WaitForJobChange"
57 58 
REQ_CANCEL_JOB = "CancelJob"
58 59 
REQ_ARCHIVE_JOB = "ArchiveJob"
......
78 79 
  REQ_AUTO_ARCHIVE_JOBS,
79 80 
  REQ_CANCEL_JOB,
80 81 
  REQ_CHANGE_JOB_PRIORITY,
82 
  REQ_PICKUP_JOB,
81 83 
  REQ_QUERY,
82 84 
  REQ_QUERY_CLUSTER_INFO,
83 85 
  REQ_QUERY_CONFIG_VALUES,
......
479 481 
  def SetWatcherPause(self, until):
480 482 
    return self.CallMethod(REQ_SET_WATCHER_PAUSE, (until, ))
481 483 

  		





  
  484
  
    
  def PickupJob(self, job):


  		





  
  485
  
    
    return self.CallMethod(REQ_PICKUP_JOB, (job,))


  		





  
  486
  
    

  		





  482
  487
  
    
  def SubmitJob(self, ops):


  		





  483
  488
  
    
    ops_state = map(lambda op: op.__getstate__(), ops)


  		





  484
  489
  
    
    return self.CallMethod(REQ_SUBMIT_JOB, (ops_state, ))


  		












Also available in:
  Unified diff