ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/COMP/CRAB/python/SchedulerCondor.py
(Generate patch)

Comparing COMP/CRAB/python/SchedulerCondor.py (file contents):
Revision 1.6 by ewv, Thu May 29 19:20:40 2008 UTC vs.
Revision 1.27 by ewv, Tue Aug 18 15:00:37 2009 UTC

# Line 1 | Line 1
1 + """
2 + Implements the vanilla (local) Condor scheduler
3 + """
4 +
5   __revision__ = "$Id$"
6   __version__ = "$Revision$"
7  
8 < from Scheduler import Scheduler
9 < from SchedulerLocal import SchedulerLocal
6 < from crab_exceptions import *
7 < from crab_util import *
8 < from crab_logger import Logger
9 < import common
8 > from SchedulerLocal  import SchedulerLocal
9 > from crab_exceptions import CrabException
10  
11 + import common
12   import os
13 <
14 < #  Naming convention:
14 < #  methods starting with 'ws' are responsible to provide
15 < #  corresponding part of the job script ('ws' stands for 'write script').
13 > import socket
14 > import sha
15  
16   class SchedulerCondor(SchedulerLocal) :
18
19  def __init__(self):
20    Scheduler.__init__(self,"CONDOR")
21    return
22
23
24  def configure(self, cfg_params):
25    SchedulerLocal.configure(self, cfg_params)
26    self.environment_unique_identifier ='${HOSTNAME}_${CONDOR_ID}_' + common._db.queryTask('name')
27    return
28
29
30  def sched_parameter(self,i,task):
31    """
32    Return scheduler-specific parameters
33    """
34    index = int(common._db.nJobs()) - 1
35    sched_param= ''
36
37    for i in range(index):
38      pass
39
40    return sched_param
41
42
43  def realSchedParams(self,cfg_params):
44    """
45    Return dictionary with specific parameters, to use
46    with real scheduler
17      """
18 +    Class to implement the vanilla (local) Condor scheduler
19 +     Naming convention:  Methods starting with 'ws' provide
20 +     the corresponding part of the job script
21 +     ('ws' stands for 'write script').
22 +    """
23 +
24 +    def __init__(self):
25 +        SchedulerLocal.__init__(self,"CONDOR")
26 +        self.datasetPath   = None
27 +        self.selectNoInput = None
28 +        self.return_data   = 0
29 +        self.copy_data     = 0
30 +
31 +        self.environment_unique_identifier = None
32 +        return
33 +
34 +
35 +    def configure(self, cfg_params):
36 +        """
37 +        Configure the scheduler with the config settings from the user
38 +        """
39 +
40 +        SchedulerLocal.configure(self, cfg_params)
41 +
42 +        try:
43 +            tmp =  cfg_params['CMSSW.datasetpath']
44 +            if tmp.lower() == 'none':
45 +                self.datasetPath = None
46 +                self.selectNoInput = 1
47 +            else:
48 +                self.datasetPath = tmp
49 +                self.selectNoInput = 0
50 +        except KeyError:
51 +            msg = "Error: datasetpath not defined "
52 +            raise CrabException(msg)
53 +
54 +        self.return_data = cfg_params.get('USER.return_data', 0)
55 +        self.copy_data   = cfg_params.get("USER.copy_data", 0)
56 +
57 +        self.proxyValid = 0
58 +        self.dontCheckProxy = int(cfg_params.get("GRID.dont_check_proxy", 0))
59 +        self.proxyServer = cfg_params.get("GRID.proxy_server", 'myproxy.cern.ch')
60 +        common.logger.debug('Setting myproxy server to ' + self.proxyServer)
61 +
62 +        self.group = cfg_params.get("GRID.group", None)
63 +        self.role  = cfg_params.get("GRID.role", None)
64 +        self.VO    = cfg_params.get('GRID.virtual_organization', 'cms')
65 +
66 +        self.checkProxy()
67 +
68 +        return
69 +
70 +    def envUniqueID(self):
71 +        taskHash = sha.new(common._db.queryTask('name')).hexdigest()
72 +        id = "https://" + socket.gethostname() + '/' + taskHash + "/${NJob}"
73 +        return id
74 +
75 +    def sched_parameter(self, i, task):
76 +        """
77 +        Return scheduler-specific parameters
78 +        """
79 +        req = ''
80 +        if self.EDG_addJdlParam:
81 +            if self.EDG_addJdlParam[-1] == '':
82 +                self.EDG_addJdlParam = self.EDG_addJdlParam[:-1]
83 +            for p in self.EDG_addJdlParam:
84 +                req += p.strip()+';\n'
85 +
86 +        return req
87 +
88 +
89 +    def realSchedParams(self, cfg_params):
90 +        """
91 +        Return dictionary with specific parameters, to use with real scheduler
92 +        """
93 +
94 +        tmpDir = os.path.join(common.work_space.shareDir(),'.condor_temp')
95 +        tmpDir = os.path.join(common.work_space.shareDir(),'.condor_temp')
96 +        jobDir = common.work_space.jobDir()
97 +        params = {'tmpDir':tmpDir,
98 +                  'jobDir':jobDir}
99 +        return params
100 +
101 +
102 +    def listMatch(self, seList, full):
103 +        """
104 +        Check the compatibility of available resources
105 +        """
106 +
107 +        return [True]
108 +
109 +
110 +    def decodeLogInfo(self, fileName):
111 +        """
112 +        Parse logging info file and return main info
113 +        """
114 +
115 +        import CondorGLoggingInfo
116 +        loggingInfo = CondorGLoggingInfo.CondorGLoggingInfo()
117 +        reason = loggingInfo.decodeReason(fileName)
118 +        return reason
119 +
120 +
121 +    def wsCopyOutput(self):
122 +        """
123 +        Write a CopyResults part of a job script, e.g.
124 +        to copy produced output into a storage element.
125 +        """
126 +        txt = self.wsCopyOutput_comm()
127 +        return txt
128 +
129 +
130 +    def wsExitFunc(self):
131 +        """
132 +        Returns the part of the job script which runs prior to exit
133 +        """
134 +
135 +        txt = '\n'
136 +        txt += '#\n'
137 +        txt += '# EXECUTE THIS FUNCTION BEFORE EXIT \n'
138 +        txt += '#\n\n'
139 +
140 +        txt += 'func_exit() { \n'
141 +        txt += self.wsExitFunc_common()
142 +
143 +        txt += '    tar zcvf ${out_files}.tgz  ${final_list}\n'
144 +        txt += '    cp  ${out_files}.tgz $_CONDOR_SCRATCH_DIR/\n'
145 +        txt += '    cp  crab_fjr_$NJob.xml $_CONDOR_SCRATCH_DIR/\n'
146 +
147 +        txt += '    exit $job_exit_code\n'
148 +        txt += '}\n'
149 +
150 +        return txt
151 +
152 +    def wsInitialEnvironment(self):
153 +        """
154 +        Returns part of a job script which does scheduler-specific work.
155 +        """
156 +
157 +        txt  = '\n# Written by SchedulerCondor::wsInitialEnvironment\n'
158 +        txt += 'echo "Beginning environment"\n'
159 +        txt += 'printenv | sort\n'
160 +
161 +        txt += 'middleware='+self.name()+' \n'
162 +        txt += 'if [ -e /opt/d-cache/srm/bin ]; then\n'
163 +        txt += '  export PATH=${PATH}:/opt/d-cache/srm/bin\n'
164 +        txt += 'fi\n'
165  
166 <    tmpDir = os.path.join(common.work_space.shareDir(),'.condor_temp')
50 <    params = {'tmpDir':tmpDir}
51 <    return  params
52 <
53 <
54 <  def decodeLogInfo(self, file):
55 <    """
56 <    Parse logging info file and return main info
57 <    """
58 <    import CondorGLoggingInfo
59 <    loggingInfo = CondorGLoggingInfo.CondorGLoggingInfo()
60 <    reason = loggingInfo.decodeReason(file)
61 <    return reason
62 <
63 <
64 <  def wsExitFunc(self):
65 <    """
66 <    """
67 <    txt = '\n'
68 <    txt += '#\n'
69 <    txt += '# EXECUTE THIS FUNCTION BEFORE EXIT \n'
70 <    txt += '#\n\n'
71 <
72 <    txt += 'func_exit() { \n'
73 <    txt += '    if [ $PYTHONPATH ]; then \n'
74 <    txt += '        update_fjr\n'
75 <    txt += '    fi\n'
76 <    txt += '    for file in $filesToCheck ; do\n'
77 <    txt += '        if [ -e $file ]; then\n'
78 <    txt += '            echo "tarring file $file in  $out_files"\n'
79 <    txt += '        else\n'
80 <    txt += '            echo "WARNING: output file $file not found!"\n'
81 <    txt += '        fi\n'
82 <    txt += '    done\n'
83 <    txt += '    final_list=$filesToCheck\n'
84 <    txt += '    echo "JOB_EXIT_STATUS = $job_exit_code"\n'
85 <    txt += '    echo "JobExitCode=$job_exit_code" >> $RUNTIME_AREA/$repo\n'
86 <    txt += '    dumpStatus $RUNTIME_AREA/$repo\n'
87 <    txt += '    tar zcvf ${out_files}.tgz  ${final_list}\n'
88 <    txt += '    cp  ${out_files}.tgz $ORIG_WD/\n'
89 <    txt += '    cp  crab_fjr_$NJob.xml $ORIG_WD/\n'
90 <
91 <    txt += '    exit $job_exit_code\n'
92 <    txt += '}\n'
93 <
94 <    return txt
95 <
96 <  def wsInitialEnvironment(self):
97 <    """
98 <    Returns part of a job script which does scheduler-specific work.
99 <    """
100 <
101 <    txt  = '\n# Written by SchedulerCondor::wsInitialEnvironment\n'
102 <    txt += 'echo "Beginning environment"\n'
103 <    txt += 'printenv | sort\n'
104 <
105 <    txt += 'middleware='+self.name()+' \n'
106 <    txt += """
166 >        txt += """
167   if [ $_CONDOR_SCRATCH_DIR ] && [ -d $_CONDOR_SCRATCH_DIR ]; then
168 <    ORIG_WD=`pwd`
109 <    echo "Change from $ORIG_WD to Condor scratch directory: $_CONDOR_SCRATCH_DIR"
168 >    echo "cd to Condor scratch directory: $_CONDOR_SCRATCH_DIR"
169      if [ -e ../default.tgz ] ;then
170        echo "Found ISB in parent directory (Local Condor)"
171        cp ../default.tgz $_CONDOR_SCRATCH_DIR
# Line 115 | Line 174 | if [ $_CONDOR_SCRATCH_DIR ] && [ -d $_CO
174   fi
175   """
176  
177 <    return txt
177 >        return txt
178 >
179 >
180 >    def sched_fix_parameter(self):
181 >        """
182 >        Returns string with requirements and scheduler-specific parameters
183 >        """
184 >
185 >        if self.EDG_requirements:
186 >            req = self.EDG_requirements
187 >            taskReq = {'commonRequirements':req}
188 >            common._db.updateTask_(taskReq)

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines