Skip to content

Commit d4dc20e

Browse files
committed
Debug job resume
1 parent 67cf755 commit d4dc20e

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

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

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -482,6 +482,7 @@ public static Resumer create(JobContext ctx) throws PipelineJobException
482482
ret.setLocalWorkDir(ctx.getWorkDir().getDir());
483483
ret._fileManager.onResume(ctx.getJob(), ctx.getWorkDir());
484484

485+
ctx.getLogger().debug("Cached steps: " + StringUtils.join(ret._stepOutputs.keySet(), ", "));
485486
}
486487

487488
return ret;
@@ -499,7 +500,7 @@ public List<SingleCellStep.SeuratObjectWrapper> getSeuratFromStep(int stepIdx)
499500

500501
public void setStepComplete(Logger log, SingleCellStep step, int stepIdx, RecordedAction action, List<SingleCellStep.SeuratObjectWrapper> seurat, File markdown, File html) throws PipelineJobException
501502
{
502-
log.info("Marking step complete: " + step.getProvider().getName());
503+
log.info("Marking step complete: " + step.getProvider().getName() + ", " + stepIdx);
503504

504505
if (seurat != null)
505506
{
@@ -509,6 +510,11 @@ public void setStepComplete(Logger log, SingleCellStep step, int stepIdx, Record
509510
action.addOutput(markdown, "Markdown File", true);
510511
action.addOutput(html, "HTML Report", false);
511512

513+
if (_stepOutputs.containsKey(stepIdx))
514+
{
515+
log.debug("Step already marked as done: " + step.getProvider().getName() + " / " +stepIdx);
516+
}
517+
512518
_stepOutputs.put(stepIdx, seurat);
513519
_markdowns.put(stepIdx, markdown);
514520
_htmlFiles.put(stepIdx, html);

0 commit comments

Comments
 (0)