Skip to content

Commit 903be7f

Browse files
committed
Dont write record of references without lineages
1 parent aec659a commit 903be7f

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

SequenceAnalysis/src/org/labkey/sequenceanalysis/run/analysis/ImmunoGenotypingAnalysis.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,10 @@ public void init(SequenceAnalysisJobSupport support) throws PipelineJobException
133133
{
134134
List<Integer> refNtIds = new TableSelector(SequenceAnalysisSchema.getInstance().getSchema().getTable(SequenceAnalysisSchema.TABLE_REF_LIBRARY_MEMBERS), PageFlowUtil.set("ref_nt_id"), new SimpleFilter(FieldKey.fromString("library_id"), genome.getGenomeId()), null).getArrayList(Integer.class);
135135
new TableSelector(SequenceAnalysisSchema.getInstance().getSchema().getTable(SequenceAnalysisSchema.TABLE_REF_NT_SEQUENCES), PageFlowUtil.set("rowid", "name", "lineage"), new SimpleFilter(FieldKey.fromString("rowid"), refNtIds, CompareType.IN), null).forEachResults(rs -> {
136-
writer.writeNext(new String[]{rs.getString(FieldKey.fromString("name")), rs.getString(FieldKey.fromString("lineage"))});
136+
if (rs.getString(FieldKey.fromString("lineage")) != null)
137+
{
138+
writer.writeNext(new String[]{rs.getString(FieldKey.fromString("name")), rs.getString(FieldKey.fromString("lineage"))});
139+
}
137140
});
138141
}
139142
catch (IOException e)
@@ -215,6 +218,8 @@ public Output performAnalysisPerSampleRemote(Readset rs, File inputBam, Referenc
215218
{
216219
options.add("-referenceToLineageFile");
217220
options.add(lineageMapFile.getPath());
221+
222+
output.addIntermediateFile(lineageMapFile);
218223
}
219224
else
220225
{

0 commit comments

Comments
 (0)