|
26 | 26 | import org.labkey.api.query.InvalidKeyException; |
27 | 27 | import org.labkey.api.query.QueryService; |
28 | 28 | import org.labkey.api.query.QueryUpdateServiceException; |
| 29 | +import org.labkey.api.sequenceanalysis.SequenceAnalysisService; |
29 | 30 | import org.labkey.api.sequenceanalysis.SequenceOutputFile; |
30 | 31 | import org.labkey.api.sequenceanalysis.model.ReadData; |
31 | 32 | import org.labkey.api.sequenceanalysis.model.Readset; |
@@ -271,7 +272,7 @@ private Map<String, Integer> getCachedReadCounts(SequenceAnalysisJobSupport supp |
271 | 272 | @Override |
272 | 273 | public void complete(PipelineJob job, List<Readset> readsets, List<SequenceOutputFile> outputsCreated) throws PipelineJobException |
273 | 274 | { |
274 | | - Readset rs = readsets.get(0); |
| 275 | + Readset rs = SequenceAnalysisService.get().getReadset(readsets.get(0).getRowId(), job.getUser()); |
275 | 276 | List<Map<String, Object>> rows = new ArrayList<>(); |
276 | 277 |
|
277 | 278 | for (ReadData rd : rs.getReadData()) |
@@ -341,6 +342,7 @@ public void complete(PipelineJob job, List<Readset> readsets, List<SequenceOutpu |
341 | 342 | TableInfo ti = QueryService.get().getUserSchema(job.getUser(), target, SequenceAnalysisSchema.SCHEMA_NAME).getTable(SequenceAnalysisSchema.TABLE_READ_DATA); |
342 | 343 | try |
343 | 344 | { |
| 345 | + job.getLogger().debug("Updating ReadData: " + rows.size()); |
344 | 346 | ti.getUpdateService().updateRows(job.getUser(), target, rows, rows, null, null); |
345 | 347 | } |
346 | 348 | catch (InvalidKeyException | BatchValidationException | QueryUpdateServiceException | SQLException e) |
|
0 commit comments