CRAB/python/ResubmitterServer.py

from SubmitterServer import SubmitterServer
from Resubmitter  import Resubmitter
import common
from crab_util import *

class ResubmitterServer(SubmitterServer, Resubmitter):
    def __init__(self, cfg_params, jobs):
        self.cfg_params = cfg_params

        self.copy_data = int(cfg_params.get('USER.copy_data',0))
        self.check_RemoteDir =  int(cfg_params.get('USER.check_user_remote_dir',0))

        nj_list = []

        # get updated status from server 
        try:
            from StatusServer import StatusServer
            stat = StatusServer(self.cfg_params)
            warning_msg = stat.resynchClientSide()
            if warning_msg is not None:
                common.logger.info(warning_msg)
        except:
            pass

        nj_list = self.checkAllowedJob(jobs,nj_list)
       
        SubmitterServer.__init__(self, cfg_params, nj_list, 'range')
 
        return

        
Revision:	1.5
Committed:	Wed Apr 28 15:15:30 2010 UTC (15 years ago) by mcinquil
Content type:	text/x-python
Branch:	MAIN
CVS Tags:	CRAB_2_8_4_patch3, CRAB_2_8_5_pre2, CRAB_2_8_4_patch2, CRAB_2_8_5_pre1, CRAB_2_8_4_patch1, CRAB_2_8_4, CRAB_2_8_4_pre5, CRAB_2_8_4_pre4, CRAB_2_8_4_pre3, CRAB_2_8_4_pre2, CRAB_2_8_4_pre1, CRAB_2_8_3, CRAB_2_8_3_pre4, CRAB_2_8_3_pre3, CRAB_2_8_3_pre2, CRAB_2_8_3_pre1, CRAB_2_8_2_patch1, CRAB_2_8_2, CRAB_2_8_2_pre5, CRAB_2_8_2_pre4, CRAB_2_8_2_pre3, CRAB_2_8_2_pre2, CRAB_2_8_2_pre1, CRAB_2_8_1, CRAB_2_8_0, CRAB_2_8_0_pre1, CRAB_2_7_10_pre3, CRAB_2_7_9_patch2_pre1, CRAB_2_7_10_pre2, CRAB_2_7_10_pre1, CRAB_2_7_9_patch1, CRAB_2_7_9, CRAB_2_7_9_pre5, CRAB_2_7_9_pre4, CRAB_2_7_9_pre3, CRAB_2_7_9_pre2, CRAB_2_7_8_patch2, CRAB_2_7_9_pre1, CRAB_2_7_8_patch2_pre1, CRAB_2_7_8_patch1, CRAB_2_7_8_patch1_pre1, CRAB_2_7_8, CRAB_2_7_8_pre3, CRAB_2_7_8_pre2, CRAB_2_7_8_dash3, CRAB_2_7_8_dash2, CRAB_2_7_8_dash, CRAB_2_7_7_patch1, CRAB_2_7_7_patch1_pre1, CRAB_2_7_8_pre1, CRAB_2_7_7, CRAB_2_7_7_pre2, CRAB_2_7_7_pre1, CRAB_2_7_6_patch1, CRAB_2_7_6, CRAB_2_7_6_pre1, CRAB_2_7_5_patch1, CRAB_2_7_5, CRAB_2_7_5_pre3, CRAB_2_7_5_pre2, CRAB_2_7_5_pre1, CRAB_2_7_4_patch1, CRAB_2_7_4, CRAB_2_7_4_pre6, CRAB_2_7_4_pre5, CRAB_2_7_4_pre4, CRAB_2_7_4_pre3, CRAB_2_7_4_pre2, CRAB_2_7_4_pre1, CRAB_2_7_3, CRAB_2_7_3_pre3, CRAB_2_7_3_pre3_beta, CRAB_2_7_3_pre2, CRAB_2_7_3_pre2_beta, CRAB_2_7_3_pre1, CRAB_2_7_3_beta3, CRAB_2_7_3_beta2, CRAB_2_7_3_beta1, CRAB_2_7_3_beta
Changes since 1.4:	+3 -1 lines
Log Message:	warning message on c-s communication at the end
#	User	Rev	Content
1	spiga	1.1	from SubmitterServer import SubmitterServer
2			from Resubmitter import Resubmitter
3			import common
4			from crab_util import *
5
6			class ResubmitterServer(SubmitterServer, Resubmitter):
7			def __init__(self, cfg_params, jobs):
8			self.cfg_params = cfg_params
9
10	spiga	1.4	self.copy_data = int(cfg_params.get('USER.copy_data',0))
11			self.check_RemoteDir = int(cfg_params.get('USER.check_user_remote_dir',0))
12
13	spiga	1.1	nj_list = []
14	spiga	1.2
15			# get updated status from server
16			try:
17			from StatusServer import StatusServer
18			stat = StatusServer(self.cfg_params)
19	mcinquil	1.5	warning_msg = stat.resynchClientSide()
20			if warning_msg is not None:
21			common.logger.info(warning_msg)
22	spiga	1.2	except:
23			pass
24
25	slacapra	1.3	nj_list = self.checkAllowedJob(jobs,nj_list)
26	spiga	1.1
27			SubmitterServer.__init__(self, cfg_params, nj_list, 'range')
28
29			return
30
31