| /dports/misc/py-toil/toil-5.4.0/src/toil/jobStores/ |
| H A D | fileJobStore.py | 191 def getPublicUrl(self, jobStoreFileID): argument
192 self._checkJobStoreFileID(jobStoreFileID)
427 return jobStoreFileID
430 self._checkJobStoreFileID(jobStoreFileID)
440 self._checkJobStoreFileID(jobStoreFileID)
507 def deleteFile(self, jobStoreFileID): argument
508 if not self.fileExists(jobStoreFileID):
512 def fileExists(self, jobStoreFileID): argument
529 def getFileSize(self, jobStoreFileID): argument
547 self._checkJobStoreFileID(jobStoreFileID)
[all …]
|
| H A D | abstractJobStore.py | 69 def __init__(self, jobStoreFileID: FileID):
89 message = "File '%s' does not exist." % jobStoreFileID
388 self._defaultExportFile(otherCls, jobStoreFileID, url)
404 with self.readFileStream(jobStoreFileID) as readable:
405 if getattr(jobStoreFileID, 'executable', False):
406 executable = jobStoreFileID.executable
663 if self.fileExists(jobStoreFileID):
664 return jobStoreFileID
1027 def deleteFile(self, jobStoreFileID: str) -> None:
1037 def fileExists(self, jobStoreFileID: str) -> bool:
[all …]
|
| H A D | googleJobStore.py | 268 if not self.fileExists(jobStoreFileID):
269 raise NoSuchFileException(jobStoreFileID)
274 if getattr(jobStoreFileID, 'executable', False):
283 def deleteFile(self, jobStoreFileID): argument
284 self._delete(jobStoreFileID)
287 def fileExists(self, jobStoreFileID): argument
291 def getFileSize(self, jobStoreFileID): argument
292 if not self.fileExists(jobStoreFileID):
296 def updateFile(self, jobStoreFileID, localFilePath): argument
430 def _delete(self, jobStoreFileID): argument
[all …]
|
| /dports/misc/py-toil/toil-5.4.0/src/toil/jobStores/aws/ |
| H A D | jobStore.py | 435 info = self.FileInfo.loadOrCreate(jobStoreFileID=jobStoreFileID,
570 def fileExists(self, jobStoreFileID): argument
573 def getFileSize(self, jobStoreFileID): argument
574 if not self.fileExists(jobStoreFileID):
602 def deleteFile(self, jobStoreFileID): argument
603 info = self.FileInfo.load(jobStoreFileID)
650 def getPublicUrl(self, jobStoreFileID): argument
956 def exists(cls, jobStoreFileID): argument
965 def load(cls, jobStoreFileID): argument
975 self = cls.load(jobStoreFileID)
[all …]
|
| /dports/misc/py-toil/toil-5.4.0/src/toil/utils/ |
| H A D | toilDebugFile.py | 43 for jobStoreFileID in jobStoreHits:
45 jobStore.readFile(jobStoreFileID,
47 os.path.basename(jobStoreFileID)),
|
| /dports/misc/py-toil/toil-5.4.0/src/toil/ |
| H A D | job.py | 1450 with self._promiseJobStore.writeFileStream() as (fileHandle, jobStoreFileID):
1453 self._rvs[path].append(jobStoreFileID)
1454 return self._promiseJobStore.config.jobStore, jobStoreFileID
2303 for jobStoreFileID in Promise.filesToDelete:
2306 fileStore.deleteGlobalFile(FileID(jobStoreFileID, 0))
2843 jobStoreLocator, jobStoreFileID = self.job.registerPromise(self.path)
2846 return self.__class__, (jobStoreLocator, jobStoreFileID)
2859 def _resolve(cls, jobStoreLocator, jobStoreFileID): argument
2864 cls.filesToDelete.add(jobStoreFileID)
2865 with cls._jobstore.readFileStream(jobStoreFileID) as fileHandle:
|
| H A D | common.py | 1027 def exportFile(self, jobStoreFileID, dstUrl): argument
1035 self._jobStore.exportFile(jobStoreFileID, dstUrl)
|
| /dports/misc/py-toil/toil-5.4.0/src/toil/fileStores/ |
| H A D | nonCachingFileStore.py | 102 def exportFile(self, jobStoreFileID, dstUrl): argument
103 self.jobStore.exportFile(jobStoreFileID, dstUrl)
|
| H A D | abstractFileStore.py | 409 def exportFile(self, jobStoreFileID, dstUrl): argument
|
| H A D | cachingFileStore.py | 1750 def exportFile(self, jobStoreFileID, dstUrl): argument
1763 self.jobStore.exportFile(jobStoreFileID, dstUrl)
|