Source Code for Module Ganga.Lib.MonitoringServices.Dashboard.LCGUtil

 1  """LCG meta-data utilities. 
 2   
 3  N.B. This code is under development and should not generally be used or relied upon. 
 4   
 5  """ 
 6   
 7  from Ganga.Lib.MonitoringServices.Dashboard import CommonUtil 
 8   
 9  #----- client meta-data builders -----  
10  #TODO: add error handling code in following methods 
11   
12 -def cl_dest_ce(job): 
13      """Build dest_ce. Only run on client.""" 
14      return CommonUtil.strip_to_none(job.backend.actualCE) 
15   
16 -def cl_execution_backend(job): 
17      """Build execution_backend. Only run on client.""" 
18      return job.backend._name 
19   
20 -def cl_grid_exit_code(job): 
21      """Build grid_exit_code. Only run on client.""" 
22      return CommonUtil.strip_to_none(job.backend.exitcode_lcg) 
23   
24 -def cl_grid_exit_reason(job): 
25      """Build grid_exit_reason. Only run on client.""" 
26      return CommonUtil.strip_to_none(job.backend.reason) 
27   
28 -def cl_grid_job_id(job): 
29      """Build grid_job_id. Only run on client.""" 
30      return CommonUtil.strip_to_none(job.backend.id) 
31   
32 -def cl_ownerdn(): 
33      """Build ownerdn. Only run on client.""" 
34      from Ganga.GPIDev import Credentials 
35      proxy = Credentials.getCredential('GridProxy') 
36      ownerdn = proxy.info('-subject') 
37      return CommonUtil.strip_to_none(ownerdn) 
38   
39 -def cl_grid_status(job): 
40      """Build grid_status. Only run on client.""" 
41      return CommonUtil.strip_to_none(job.backend.status) 
42   
43 -def cl_job_id_inside_the_task(job): 
44      """Build job_id_inside_the_task. Only run on client.""" 
45      if job.master is None: 
46          job_id_inside_the_task = 0 
47      else: 
48          job_id_inside_the_task = job.id 
49      return job_id_inside_the_task 
50   
51 -def cl_task_name(job): 
52      """Build task_name. Only run on client.""" 
53      # format: ganga:<job.info.uuid>:<job.name> 
54      if job.master: 
55          job = job.master 
56      task_name = 'ganga:%s:%s' % (job.info.uuid, job.name,) 
57      return task_name 
58   
59 -def cl_unique_job_id(job): 
60      """Build unique_job_id. Only run on client.""" 
61      return job.info.uuid 
62   
63   
64  #----- worker node meta-data builders -----  
65  #TODO: add error handling code in following methods 
66   
67 -def wn_dest_ce(ji): 
68      """Build dest_ce. Only run on worker node.""" 
69      dest_ce = CommonUtil.env('GLOBUS_CE') 
70      if not dest_ce: 
71          dest_ce = CommonUtil.stdout('edg-brokerinfo getCE') 
72      if not dest_ce: 
73          dest_ce = CommonUtil.stdout('glite-brokerinfo getCE') 
74      return CommonUtil.strip_to_none(dest_ce) 
75   
76 -def wn_dest_site(ji): 
77      """Build dest_site. Only run on worker node.""" 
78      return CommonUtil.env('SITE_NAME') 
79       
80 -def wn_dest_wn(): 
81      """Build dest_wn. Only run on worker node.""" 
82      return CommonUtil.hostname() 
83   
84 -def wn_grid_job_id(ji): 
85      """Build grid_job_id. Only run on worker node.""" 
86      grid_job_id = CommonUtil.env('EDG_WL_JOBID') 
87      if not grid_job_id: 
88          grid_job_id = CommonUtil.env('GLITE_WMS_JOBID') 
89      return grid_job_id 
90