import compbio.engine.Configurator;\r
import compbio.engine.client.ConfiguredExecutable;\r
import compbio.engine.client.Executable;\r
+import compbio.engine.client.SkeletalExecutable;\r
import compbio.metadata.ChunkHolder;\r
import compbio.metadata.JobStatus;\r
import compbio.metadata.JobSubmissionException;\r
}\r
\r
ConfiguredExecutable<Tcoffee> init(List<FastaSequence> sequences)\r
- throws JobSubmissionException {\r
- Tcoffee tcoffee = new Tcoffee();\r
- tcoffee.setInput("fasta.in").setOutput("fasta.out");\r
- ConfiguredExecutable<Tcoffee> confCoffee = Configurator\r
- .configureExecutable(tcoffee, sequences);\r
- if (confCoffee.getExecProvider() == Executable.ExecProvider.Cluster) {\r
- int clusterCpuNum = Tcoffee.getClusterCpuNum();\r
- if (clusterCpuNum != 0) {\r
- tcoffee.setNCore(clusterCpuNum);\r
- }\r
- }\r
- return confCoffee;\r
+ throws JobSubmissionException {\r
+ Tcoffee tcoffee = new Tcoffee();\r
+ tcoffee.setInput("fasta.in").setOutput("fasta.out");\r
+ ConfiguredExecutable<Tcoffee> confCoffee = Configurator\r
+ .configureExecutable(tcoffee, sequences);\r
+ if (confCoffee.getExecProvider() == Executable.ExecProvider.Cluster) {\r
+ int clusterCpuNum = SkeletalExecutable.getClusterCpuNum(Tcoffee.class);\r
+ if (clusterCpuNum != 0) {\r
+ tcoffee.setNCore(clusterCpuNum);\r
+ }\r
+ }\r
+ return confCoffee;\r
}\r
\r
@Override\r