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

Comparing COMP/CRAB/python/GetOutput.py (file contents):
Revision 1.30 by fanzago, Fri Aug 8 16:30:46 2008 UTC vs.
Revision 1.31 by fanzago, Mon Aug 11 09:16:17 2008 UTC

# Line 8 | Line 8 | class GetOutput(Actor):
8          self.cfg_params = args[0]
9          self.jobs = args[1]
10          
11 +        self.log=0
12          self.outDir = self.cfg_params.get('USER.outputdir' ,common.work_space.resDir())
13          if ( self.outDir[-1] != '/' ) : self.outDir = self.outDir + '/'
14          self.logDir = self.cfg_params.get('USER.logdir' ,common.work_space.resDir())
15          if ( self.logDir[-1] != '/' ) : self.logDir = self.logDir + '/'
16 +        if self.logDir != self.outDir:
17 +            self.log=1
18          self.return_data = self.cfg_params.get('USER.return_data',0)
19  
20          self.possible_status = {
# Line 209 | Line 212 | class GetOutput(Actor):
212                  cmd_out = runCommand(cmd)  
213                  common.logger.write(str(cmd_out))
214                  common.logger.debug(3,str(cmd_out))
215 +            if self.log == 1:    
216 +                LogDir_Base=self.logDir+'Submission_'
217 +                if not os.path.isdir( LogDir_Base + str(i) + '/'):
218 +                    cmd=('mkdir '+ LogDir_Base + str(i) + '/  >& /dev/null')
219 +                    cmd_out = runCommand(cmd)  
220 +                    common.logger.write(str(cmd_out))
221 +                    common.logger.debug(3,str(cmd_out))
222          for i in range(len(self.list_id)):
223              id = self.list_id[i]
224              if sub_id[i] > 1 :
225 <                cmd='mv '+self.outDir+'*_'+str(self.list_id[i])+'.* ' + OutDir_Base + str(sub_id[i]-1) + '/  >& /dev/null'  
225 >                cmd='mv '+self.outDir+'*_'+str(self.list_id[i])+'.* ' + OutDir_Base + str(sub_id[i]-1) + '/  >& /dev/null'
226              #else:
227              #    cmd='mv '+self.outDir+'*_'+str(self.list_id[i])+'.* ' + OutDir_Base + str(sub_id[i]) + '/  >& /dev/null'
228              try:
# Line 224 | Line 234 | class GetOutput(Actor):
234                  common.logger.write(msg)
235                  common.logger.debug(3,msg)
236                  pass
237 +            if self.log == 1:
238 +                cmdlog='mv '+self.logDir+'*_'+str(self.list_id[i])+'.* ' + LogDir_Base + str(sub_id[i]-1) + '/  >& /dev/null'
239 +                try:
240 +                    cmd_out = runCommand(cmdlog)
241 +                    common.logger.write(cmd_out)
242 +                    common.logger.debug(3,cmd_out)
243 +                except:
244 +                    msg = 'no output to move for job '+str(id)
245 +                    common.logger.write(msg)
246 +                    common.logger.debug(3,msg)
247 +                    pass
248          return

Diff Legend

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