src/Batch_SWIG/Batch_test.py

   1 #Batch_test.py
   2
   3 # pratique
   4 import readline
   5 import rlcompleter
   6 readline.parse_and_bind('tab: complete')
   7
   8 # Importation de la bibliotheque de classes Batch
   9 from libBatch_Swig import *
  10
  11 def work():
  12     # Definition d'un job...
  13     job=Job()
  14     # ... de ses parametres ...
  15     p={}
  16     p['EXECUTABLE']='/home/dutka/tmp/job'
  17     p['NAME']='MonJob'
  18     p['OUTFILE']=[('/tmp/stdout', 'stdout'), ('/tmp/stderr', 'stderr')]
  19     job.setParametre(p)
  20     # ... et de son environnement
  21     job.setEnvironnement({})
  22     print job
  23
  24     # Appel au catalogue de BatchManager pour accéder au serveur cli70cu
  25     # Instanciation du catalogue (quasi-singleton)
  26     c=BatchManagerCatalog()
  27     # Instanciation d'une Factory de BatchManager de type 'PBS'
  28     # fbm=c('PBS')
  29
  30     # Creation d'un BatchManager de type PBS sur le serveur cli70cu
  31     bm=c('PBS')('cli70cu')
  32
  33     # Soumission du job au BatchManager
  34     jobid=bm.submitJob(job)
  35     print jobid
  36
  37     # Interrogation de l'etat du job
  38     jobid.queryJob()
  39
  40     # On attend que le job soit termine
  41     try:
  42         while 1: jinfo = jobid.queryJob()
  43     except:
  44         print "Job", jobid, "is done"
  45
  46     pass
  47
  48 if __name__ == "__main__":
  49     work()
  50     pass
  51
  52
  53