TWiki> Main Web>UsersTaskForceWiki>UsersTaskForceStDenis>RStDGangaGuide>RStDGangaGuideTest001 (2005-11-15, RichardStDenis) EditAttachPDF

RStDGangaGuideTest001

I did this two ways. In one I did a clean creation of a new Hello World job and in the other I copied and modified a previous Hello World Job. Both work fine. However, I also include an example of when a CE seems to fail. I chose the CE by first submitting a Hello World job that worked, noted the CE that it went to and then directed my jobs there.

With a CE that worked, copy job

Prepare 

In [18]: j120=j4.copy()
 
In [19]: j120.backend.CE="mu6.matrix.sara.nl:2119/jobmanager-pbs-atlas"
 
In [20]: p j120
Job {
 status = 'new' ,
 name = '' ,
 inputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/120/input/' ,
 outputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/120/output/' ,
 outputsandbox = [] ,
 id = 120 ,
 inputdata = None ,
 inputsandbox = [ ] ,
 application = Executable {
    exe = '/bin/echo' ,
    env = {} ,
    args = ['Hello World']
    } ,
 backend = LCG {
    status = None ,
    actualCE = None ,
    CE = 'mu6.matrix.sara.nl:2119/jobmanager-pbs-atlas' ,
    reason = None ,
    id = None ,
    exitcode = None ,
    requirements = Requirements {
       ipconnectivity = None ,
       cputime = None ,
       other = [] ,
       memory = None ,
       software = [] ,
       walltime = None
       }
    }
 }

Submit 

 
In [21]: j120.submit
-------> j120.submit()
Ganga.GPIDev.Lib.Job               : INFO     submitting job 120
Out[21]: 1
 
In [22]: Ganga.Lib.LCG                      : INFO     job 120 has changed status to Waiting
 
Ganga.Lib.LCG                      : INFO     job 120 has changed status to Ready
Ganga.Lib.LCG                      : INFO     job 120 has been assigned to mu6.matrix.sara.nl:2119/jobmanager-pbs-atlas
Ganga.Lib.LCG                      : INFO     job 120 has changed status to Scheduled

Results 

Ganga.Lib.LCG                      : INFO     job 120 has changed status to Done (Success)
In [15]: j120=jobs[120]
 

 
In [17]: o120=file(j120.outputdir+'/stdout')
 
 
In [19]: print o120.read();
Hello World

Example of a failed CE

New Clean Job

Prepare Job 

In [13]: j117=Job()
 
In [14]: jobs
Out[14]: Statistics: 97  jobs
--------------
  ID     status           name
#  1  completed
#  2  completed
#  3  completed                                  ce-egee.bifi.unizar.es:2119/jobmanager-lcgpbs-atlas
#  4  completed                                  gridce.pi.infn.it:2119/jobmanager-lcgpbs-atlas
#  5        new                                        None
#  6        new
#  7        new
#  8        new
#  9        new
# 10        new
# 11        new
# 12        new
# 13        new
# 14        new
# 15        new
# 16        new
# 17        new
# 18        new
# 19        new
# 20        new
# 21        new
# 22        new
# 23        new
# 24        new
# 25        new
# 26        new
# 27        new
# 28        new
# 29        new
# 30        new
# 31        new
# 32        new
# 33        new
# 34        new
# 35        new
# 36        new
# 37        new
# 38        new
# 39        new
# 60        new
# 61        new
# 62        new
# 63        new
# 64        new
# 65        new
# 66        new
# 67        new
# 68        new
# 69        new
# 70        new
# 71        new
# 72        new
# 73        new
# 74        new
# 75        new
# 76        new
# 77        new
# 78        new
# 79        new
# 80        new
# 81        new
# 82        new
# 83        new
# 84        new
# 85        new
# 86        new
# 87        new
# 88        new
# 89        new
# 90        new
# 91        new
# 92        new
# 93        new
# 94        new
# 95        new
# 96        new
# 97        new
# 98        new
# 99        new
#100        new
#101        new
#102        new
#103        new
#104        new
#105        new                                        None
#106        new                                        None
#107        new
#108     failed                                  lxgate13.cern.ch:2119/jobmanager-lcglsf-grid_atlas
#109        new
#110        new                                        None
#111     failed                                        None
#112        new
#113        new                                        None
#114     failed                                        None
#115  completed                                  mu6.matrix.sara.nl:2119/jobmanager-pbs-atlas
#116     failed                                        None
#117        new
 
 
In [15]: j117.application.exe='/bin/echo'
 
In [16]: j117.backend=LCG()
 
In [17]: j117.application.args=['Hello World']
 
In [18]: j117.backend.CE='grid-ce.desy.de:2119/jobmanager-lcgpbs-short'

Submit 

  
In [19]: j117.submit
-------> j117.submit()
Ganga.GPIDev.Lib.Job               : INFO     submitting job 117
Out[19]: 1
 
---+++Results
In [20]: Ganga.Lib.LCG                      : INFO     job 117 has changed status to Aborted
In [20]: p j117
Job {
 status = 'failed' ,
 name = '' ,
 inputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/117/input/' ,
 outputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/117/output/' ,
 outputsandbox = [] ,
 id = 117 ,
 inputdata = None ,
 inputsandbox = [ ] ,
 application = Executable {
    exe = '/bin/echo' ,
    env = {} ,
    args = ['Hello World']
    } ,
 backend = LCG {
    status = 'Aborted' ,
    actualCE = None ,
    CE = 'grid-ce.desy.de:2119/jobmanager-lcgpbs-short' ,
    reason = 'Cannot plan: BrokerHelper: no compatible resources' ,
    id = 'https://gdrb03.cern.ch:9000/ZWv11UPbth2MpNYI2QhqBg' ,
    exitcode = None ,
    requirements = Requirements {
       ipconnectivity = None ,
       cputime = None ,
       other = [] ,
       memory = None ,
       software = [] ,
       walltime = None
       }
    }
 }
 
 
 
In [21]:

Cloned Job

Prepare Job 

In [1]: j4 =jobs[4]
 
In [2]: j118=j4.copy()
 
In [3]: p j118
Job {
 status = 'new' ,
 name = '' ,
 inputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/118/input/' ,
 outputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/118/output/' ,
 outputsandbox = [] ,
 id = 118 ,
 inputdata = None ,
 inputsandbox = [ ] ,
 application = Executable {
    exe = '/bin/echo' ,
    env = {} ,
    args = ['Hello World']
    } ,
 backend = LCG {
    status = None ,
    actualCE = None ,
    CE = None ,
    reason = None ,
    id = None ,
    exitcode = None ,
    requirements = Requirements {
       ipconnectivity = None ,
       cputime = None ,
       other = [] ,
       memory = None ,
       software = [] ,
       walltime = None
       }
    }
 }
 
 
 
In [4]:
In [4]: j118.backend.CE='grid-ce.desy.de:2119/jobmanager-lcgpbs-short'
 
In [5]: p j118
Job {
 status = 'new' ,
 name = '' ,
 inputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/118/input/' ,
 outputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/118/output/' ,
 outputsandbox = [] ,
 id = 118 ,
 inputdata = None ,
 inputsandbox = [ ] ,
 application = Executable {
    exe = '/bin/echo' ,
    env = {} ,
    args = ['Hello World']
    } ,
 backend = LCG {
    status = None ,
    actualCE = None ,
    CE = 'grid-ce.desy.de:2119/jobmanager-lcgpbs-short' ,
    reason = None ,
    id = None ,
    exitcode = None ,
    requirements = Requirements {
       ipconnectivity = None ,
       cputime = None ,
       other = [] ,
       memory = None ,
       software = [] ,
       walltime = None
       }
    }
 }
 
 
 
In [6]:

Submit 

In [6]: j118.submit
------> j118.submit()
Ganga.GPIDev.Lib.Job               : INFO     submitting job 118
 
Out[6]: 1

Result 

In [7]: Ganga.Lib.LCG                      : INFO     job 118 has changed status to Waiting
 
 
In [8]: Ganga.Lib.LCG                      : INFO     job 118 has changed status to Aborted
In [11]: p j118
Job {
 status = 'failed' ,
 name = '' ,
 inputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/118/input/' ,
 outputdir = '/afs/cern.ch/user/s/stdenis/gangadir/workspace/Local/118/output/' ,
 outputsandbox = [] ,
 id = 118 ,
 inputdata = None ,
 inputsandbox = [ ] ,
 application = Executable {
    exe = '/bin/echo' ,
    env = {} ,
    args = ['Hello World']
    } ,
 backend = LCG {
    status = 'Aborted' ,
    actualCE = None ,
    CE = 'grid-ce.desy.de:2119/jobmanager-lcgpbs-short' ,
    reason = 'Cannot plan: BrokerHelper: no compatible resources' ,
    id = 'https://gdrb01.cern.ch:9000/m7E_MyAXBjI-3zptyRvjcA' ,
    exitcode = None ,
    requirements = Requirements {
       ipconnectivity = None ,
       cputime = None ,
       other = [] ,
       memory = None ,
       software = [] ,
       walltime = None
       }
    }
 }
 
 
 
In [12]:

Major updates:
-- RichardStDenis - 15 Nov 2005

%RESPONSIBLE%
%REVIEW%

Edit | Attach | Watch | Print version | History: r2 < r1 | Backlinks | Raw View | WYSIWYG | More topic actions
Topic revision: r2 - 2005-11-15 - RichardStDenis
 
    • Cern Search Icon Cern Search
    • TWiki Search Icon TWiki Search
    • Google Search Icon Google Search

    Main All webs login

This site is powered by the TWiki collaboration platform Powered by PerlCopyright &© 2008-2024 by the contributing authors. All material on this collaboration platform is the property of the contributing authors.
or Ideas, requests, problems regarding TWiki? use Discourse or Send feedback