import compbio.beans.ProteinBean;
import compbio.cassandra.CassandraNativeConnector;
+import compbio.cassandra.readers.JobReader;
import compbio.cassandra.readers.SequenceReader;
import compbio.engine.archive.ArchivedJob;
}
@Override
- public String findSequence(String sequence, String program, String version) {
+ public int findSequence(String sequence, String program, String version) {
List<String> jobs = findJobs(sequence, program, version);
if (null != jobs) {
- return jobs.size() + " jobs found";
+ return jobs.size();
}
- return "no jobs found";
+ return 0;
}
@Override
return link;
}
+ @Override
+ public int jobExists(String jobid) {
+ CassandraNativeConnector dbconnector = new CassandraNativeConnector();
+ JobReader reader = new JobReader();
+ reader.setSession(dbconnector.getSession());
+ if (null != reader.readJobLog(jobid)) {
+ return 1;
+ }
+ return 0;
+ }
+
}