Mercurial > repos > yufei-luo > s_mart
comparison commons/pyRepetUnit/hmmer/HmmpfamClusterComponent.py @ 31:0ab839023fe4
Uploaded
author | m-zytnicki |
---|---|
date | Tue, 30 Apr 2013 14:33:21 -0400 |
parents | 94ab73e8a190 |
children |
comparison
equal
deleted
inserted
replaced
30:5677346472b5 | 31:0ab839023fe4 |
---|---|
1 import os | |
2 from pyRepet.launcher.Launcher import HmmpfamLauncher | |
3 | |
4 | |
5 class HmmpfamClusterComponent( object ): | |
6 | |
7 def __init__(self): | |
8 self._component = None | |
9 self._profilDatabank = "" | |
10 self._resultDir = "" | |
11 self._queryDir = "" | |
12 self._tmpDir = "" | |
13 self._jobDb = None | |
14 self._SGEQueue = "" | |
15 self._SGEGroupId = "" | |
16 | |
17 def loadConfig( self, config ): | |
18 self._profilDatabank = config.get( "profil_search","ProfilDatabank" ) | |
19 self._queryDir = config.get( "hmmer_config","query_dir" ) | |
20 self._tmpDir = config.get( "hmmer_config", "tmp_dir" ) | |
21 self._resultDir = config.get( "hmmer_config", "result_dir" ) | |
22 self._SGEQueue = config.get( "sge_config", "queue" ) | |
23 self._SGEGroupId = config.get( "sge_config", "groupid" ) | |
24 | |
25 def run(self): | |
26 params = {"param":"--informat FASTA -E 10", | |
27 "profilDB": self._profilDatabank, | |
28 "outputDir": self._resultDir, | |
29 "query": self._queryDir, | |
30 "job_table":"jobs", | |
31 "queue" : self._SGEQueue, | |
32 "groupid" : self._SGEGroupId, | |
33 "tmpDir": self._tmpDir, | |
34 "cDir" : "."} | |
35 self._component = HmmpfamLauncher(self._jobDb, params) | |
36 self._component.run() | |
37 | |
38 def clean (self): | |
39 dirToClean = self._tmpDir | |
40 os.system("rm " + dirToClean + "/*") | |
41 dirToClean = self._resultDir | |
42 os.system("rm " + dirToClean + "/*") | |
43 | |
44 def setProfilDatabank (self, profilDatabank): | |
45 self._profilDatabank = profilDatabank | |
46 | |
47 def getProfilDatabank(self): | |
48 return self._profilDatabank | |
49 | |
50 def setQueryDir(self, input): | |
51 self._queryDir = input | |
52 | |
53 def getQueryDir( self ): | |
54 return self._queryDir | |
55 | |
56 def setSubjectDir(self, input): | |
57 self._subjectDir = input | |
58 | |
59 def getSubjectDir( self ): | |
60 return self._subjectDir | |
61 | |
62 def setSGEQueue(self, queue): | |
63 self._SGEQueue = queue | |
64 | |
65 def getSGEQueue( self ): | |
66 return self._SGEQueue | |
67 | |
68 def setSGEGrouId(self, id): | |
69 self._SGEGroupId = id | |
70 | |
71 def getSGEGroupId( self ): | |
72 return self._SGEGroupId; | |
73 | |
74 def setTmpDir(self, tmpDir): | |
75 self._tmpDir = tmpDir | |
76 | |
77 def getTmpDir( self ): | |
78 return self._tmpDir | |
79 | |
80 def setResultDir(self, wkDir): | |
81 self._resultDir = wkDir | |
82 | |
83 def getResultDir(self): | |
84 return self._resultDir | |
85 | |
86 def setJobDb (self, jobDb): | |
87 self._jobDb = jobDb | |
88 | |
89 def getJobDb (self): | |
90 return self._jobDb | |
91 |