Skip to content

Commit a9d6f80

Browse files
committed
Always delete the '.done' file, so hashing will repeat after restart
1 parent b37f065 commit a9d6f80

File tree

2 files changed

+7
-10
lines changed

2 files changed

+7
-10
lines changed

singlecell/src/org/labkey/singlecell/CellHashingServiceImpl.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1358,6 +1358,13 @@ public void copyHtmlLocally(SequenceOutputHandler.JobContext ctx) throws Pipelin
13581358

13591359
Files.copy(f.toPath(), target.toPath());
13601360
}
1361+
1362+
// Also delete the .done files, so hashing will repeat if we change params:
1363+
if (f.getName().endsWith(CellHashingServiceImpl.CALL_EXTENSION + ".done"))
1364+
{
1365+
ctx.getLogger().debug("Removing hashing .done file: " + f.getName());
1366+
f.delete();
1367+
}
13611368
}
13621369
}
13631370
catch (IOException e)

singlecell/src/org/labkey/singlecell/pipeline/singlecell/RunCellHashing.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -74,16 +74,6 @@ public String getDockerContainerName()
7474
protected void onFailure(SequenceOutputHandler.JobContext ctx, String outputPrefix) throws PipelineJobException
7575
{
7676
CellHashingService.get().copyHtmlLocally(ctx);
77-
78-
// Also delete the .done files, so hashing will repeat if we change params:
79-
for (File f : ctx.getOutputDir().listFiles())
80-
{
81-
if (f.getName().endsWith(CellHashingServiceImpl.CALL_EXTENSION + ".done"))
82-
{
83-
ctx.getLogger().debug("Removing hashing .done file: " + f.getName());
84-
f.delete();
85-
}
86-
}
8777
}
8878

8979
@Override

0 commit comments

Comments
 (0)