Changeset 539 for trunk/python/Rappture
- Timestamp:
- Nov 7, 2006, 10:07:52 AM (18 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/python/Rappture/queue.py
r535 r539 151 151 else: 152 152 self._queue_vars['jobName'] = jobName 153 154 def transferFiles(self,transferFiles=[]): 155 transferFiles = list(transferFiles) 156 if (len(transferFiles) == 0) or (jobName == []): 157 return self._queue_vars['transferFiles'] 158 else: 159 self._queue_vars['transferFiles'] = transferFiles 153 160 154 161 def __convertWalltime__(self): … … 387 394 388 395 class condor (queue): 389 # this class is not working!390 396 391 397 USE_MPI = 1 … … 399 405 execArgs='', 400 406 walltime='00:01:00', 407 transferFiles=[], 401 408 flags=0 ): 402 409 … … 426 433 self.errFile("err.$(cluster).$(process)") 427 434 self.logFile("log.$(cluster)") 435 self.transferFiles(transferFiles) 428 436 429 437 def __fillStatusDict__(self): … … 583 591 584 592 if len(self._processList) == 0: 585 self.addProcess( )593 self.addProcess(inputFiles=self.transferFiles()) 586 594 587 595 submitFileData = self.__makeCondorScript__() + "\n".join(self._processList) … … 636 644 resultsDir = createDir('4321') 637 645 executable = './hello.sh' 646 txFileList = ['hello'] 638 647 shutil.copy('hello/hello.sh',resultsDir) 639 648 shutil.copy('hello/hello',resultsDir) 640 myCondorObj = condor(jobName,resultsDir,2,executable, walltime=walltime,flags=condor.USE_MPI)649 myCondorObj = condor(jobName,resultsDir,2,executable,ppn=1,walltime=walltime,transferFiles=txFileList,flags=condor.USE_MPI) 641 650 myCondorObj.submit() 642 651 myCondorObj.status()
Note: See TracChangeset
for help on using the changeset viewer.