Skip to content

Commit 64f900a

Browse files
committed
Add cleanup
1 parent 28f2b53 commit 64f900a

File tree

2 files changed

+9
-0
lines changed

2 files changed

+9
-0
lines changed

singlecell/api-src/org/labkey/api/singlecell/pipeline/AbstractSingleCellPipelineStep.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,8 @@ public Output execute(SequenceOutputHandler.JobContext ctx, List<SeuratObjectWra
4242
File rmd = createRmd(ctx, inputObjects, outputPrefix);
4343
executeR(ctx, rmd, outputPrefix);
4444

45+
ctx.getFileManager().addIntermediateFile(rmd);
46+
4547
File markdownFile = getExpectedMarkdownFile(ctx, outputPrefix);
4648
if (!markdownFile.exists())
4749
{
@@ -269,6 +271,9 @@ public static void executeR(SequenceOutputHandler.JobContext ctx, String dockerC
269271
SimpleScriptWrapper rWrapper = new SimpleScriptWrapper(ctx.getLogger());
270272
rWrapper.setWorkingDir(ctx.getOutputDir());
271273
rWrapper.execute(Arrays.asList("/bin/bash", localBashScript.getName()));
274+
275+
localRScript.delete();
276+
localBashScript.delete();
272277
}
273278

274279
protected String prepareValueForR(SeuratToolParameter pd)

singlecell/src/org/labkey/singlecell/analysis/ProcessSingleCellHandler.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -267,6 +267,7 @@ public void processFilesRemote(List<SequenceOutputFile> inputFiles, JobContext c
267267
{
268268
throw new PipelineJobException("No seurat objects produced by: " + prepareRawCounts.getProvider().getName());
269269
}
270+
currentFiles.stream().map(SingleCellStep.SeuratObjectWrapper::getFile).forEach(_resumer.getFileManager()::addIntermediateFile);
270271

271272
_resumer.setStepComplete(0, action, output0.getSeuratObjects(), output0.getMarkdownFile(), output0.getHtmlFile());
272273
}
@@ -356,6 +357,9 @@ else if (step.createsSeuratObjects())
356357
for (File markdown : _resumer.getMarkdownsInOrder())
357358
{
358359
finalMarkdown.chunks.add(new AbstractSingleCellPipelineStep.Chunk(null, null, null, Collections.emptyList(), "child='" + markdown.getName() + "'"));
360+
361+
//TODO: add markdown:
362+
//_resumer.getFileManager().addIntermediateFile(markdown);
359363
}
360364
finalMarkdown.chunks.add(new AbstractSingleCellPipelineStep.SessionInfoChunk());
361365

0 commit comments

Comments
 (0)