ViewVC Help

View File | Revision Log | Show Annotations | Root Listing

root/cvsroot/COMP/CRAB/python/DBinterface.py

Comparing COMP/CRAB/python/DBinterface.py (file contents):
Revision 1.58 by mcinquil, Tue Apr 28 12:54:19 2009 UTC vs.
Revision 1.59 by spiga, Tue May 26 10:23:00 2009 UTC

#	Line 1 | Line 1
1	–	from crab_logger import Logger
1		from crab_exceptions import *
2		from crab_util import *
3		import common
#	Line 58 | Line 57 | class DBinterface:
57		try:
58		task = common.bossSession.load(1,jobsList)
59		except Exception, e :
60	<	common.logger.debug(3, "Error while getting task : " +str(traceback.format_exc()))
60	>	common.logger.debug( "Error while getting task : " +str(traceback.format_exc()))
61		raise CrabException('Error while getting task '+str(e))
62		return task
63
#	Line 69 | Line 68 | class DBinterface:
68		try:
69		task = common.bossSession.load(1,str(n))
70		except Exception, e :
71	<	common.logger.debug(3, "Error while getting job : " +str(traceback.format_exc()))
71	>	common.logger.debug( "Error while getting job : " +str(traceback.format_exc()))
72		raise CrabException('Error while getting job '+str(e))
73		return task
74
#	Line 86 | Line 85 | class DBinterface:
85		try:
86		common.bossSession.saveTask( task )
87		except Exception, e :
89	–	# common.logger.debug(3, "Error creating task : " +str(traceback.format_exc()))
90	–	# raise CrabException('Error creating task '+str(e))
88		raise CrabException('Error creating task '+str(traceback.format_exc()))
89
90		return
#	Line 211 | Line 208 | class DBinterface:
208		CliServerParams(self)
209		headerTask= "Task Id = %-40s " %(task['name'])
210		displayReport(self,headerTask,lines)
211	<	common.logger.message(showWebMon(self.server_name))
211	>	common.logger.info(showWebMon(self.server_name))
212		if (jid ) or (server_mode == 0):
213		for job in task.jobs:
214		toPrint=''
#	Line 260 | Line 257 | class DBinterface:
257		try:
258		task = common.bossSession.loadJobDist( 1, attr )
259		except Exception, e :
260	<	common.logger.debug(3, "Error loading Jobs By distinct Attr : " +str(traceback.format_exc()))
260	>	common.logger.debug( "Error loading Jobs By distinct Attr : " +str(traceback.format_exc()))
261		raise CrabException('Error loading Jobs By distinct Attr '+str(e))
262
263		for i in task: distAttr.append(i[attr])
#	Line 274 | Line 271 | class DBinterface:
271		try:
272		task = common.bossSession.loadJobDistAttr( 1, attr_1, attr_2, list )
273		except Exception, e :
274	<	common.logger.debug(3, "Error loading Jobs By distinct Attr : " +str(traceback.format_exc()))
274	>	common.logger.debug( "Error loading Jobs By distinct Attr : " +str(traceback.format_exc()))
275		raise CrabException('Error loading Jobs By distinct Attr '+str(e))
276
277		for i in task: distAttr.append(i[attr_1])
#	Line 288 | Line 285 | class DBinterface:
285		try:
286		task = common.bossSession.loadJobsByAttr(attr )
287		except Exception, e :
288	<	common.logger.debug(3, "Error loading Jobs By Attr : " +str(traceback.format_exc()))
288	>	common.logger.debug( "Error loading Jobs By Attr : " +str(traceback.format_exc()))
289		raise CrabException('Error loading Jobs By Attr '+str(e))
290		for i in task:
291		matched.append(i[field])
#	Line 303 | Line 300 | class DBinterface:
300		try:
301		task = common.bossSession.loadJobsByRunningAttr(attr)
302		except Exception, e :
303	<	common.logger.debug(3, "Error loading Jobs By Running Attr : " +str(traceback.format_exc()))
303	>	common.logger.debug( "Error loading Jobs By Running Attr : " +str(traceback.format_exc()))
304		raise CrabException('Error loading Jobs By Running Attr '+str(e))
305		for i in task:
306		matched.append(i.runningJob[field])
#	Line 356 | Line 353 | class DBinterface:
353		# Data alignment
354		if rForJ.getAttribute('status') not in ['Created', 'Unknown']:
355		# update the status
356	<	common.logger.debug(3,"Updating DB status for job: " + str(id) + " @: " \
356	>	common.logger.debug("Updating DB status for job: " + str(id) + " @: " \
357		+ str(rForJ.getAttribute('status')) )
358		job.runningJob['statusScheduler'] = str( rForJ.getAttribute('status') )
359		if (rForJ.getAttribute('status') == 'Done' or rForJ.getAttribute('status') == 'Done (Failed)')\

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines