Skip to content

Commit 519d37a

Browse files
committed
Add validation to SequenceAnalysisMaintenanceTask
1 parent 741ace9 commit 519d37a

1 file changed

Lines changed: 28 additions & 0 deletions

File tree

SequenceAnalysis/src/org/labkey/sequenceanalysis/SequenceAnalysisMaintenanceTask.java

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import org.labkey.api.data.TableInfo;
1313
import org.labkey.api.data.TableSelector;
1414
import org.labkey.api.exp.api.ExpData;
15+
import org.labkey.api.exp.api.ExpRun;
1516
import org.labkey.api.exp.api.ExperimentService;
1617
import org.labkey.api.ldk.LDKService;
1718
import org.labkey.api.pipeline.PipeRoot;
@@ -34,6 +35,8 @@
3435

3536
import java.io.File;
3637
import java.io.IOException;
38+
import java.nio.file.Files;
39+
import java.nio.file.Path;
3740
import java.util.ArrayList;
3841
import java.util.Arrays;
3942
import java.util.Collections;
@@ -44,6 +47,7 @@
4447
import java.util.Map;
4548
import java.util.Set;
4649
import java.util.stream.Collectors;
50+
import java.util.stream.Stream;
4751

4852
/**
4953
* Created by bimber on 9/15/2014.
@@ -229,6 +233,30 @@ else if (!d.getFile().exists())
229233
log.error("Unable to find file associated with analysis: " + m.getAnalysisId() + ", " + m.getAlignmentFile() + ", " + d.getFile().getPath() + " for container: " + (c == null ? m.getContainer() : c.getPath()));
230234
}
231235
}
236+
237+
if (m.getRunId() != null)
238+
{
239+
ExpRun run = ExperimentService.get().getExpRun(m.getRunId());
240+
if (run == null)
241+
{
242+
log.error("Missing runId: " + m.getRunId());
243+
}
244+
else
245+
{
246+
try (Stream<Path> stream = Files.walk(run.getFilePathRootPath()))
247+
{
248+
List<Path> files = stream.filter(x -> x.getFileName().startsWith("core.")).toList();
249+
if (!files.isEmpty())
250+
{
251+
files.forEach(x -> log.error("Found core file: " + x.toFile().getPath()));
252+
}
253+
}
254+
catch (IOException e)
255+
{
256+
log.error(e.getMessage());
257+
}
258+
}
259+
}
232260
}
233261
}
234262

0 commit comments

Comments
 (0)