Skip to content

Commit 723d3d4

Browse files
committed
More visibility into orphan aligner indexes
1 parent 2fb3d8c commit 723d3d4

File tree

2 files changed

+14
-4
lines changed

2 files changed

+14
-4
lines changed

SequenceAnalysis/src/org/labkey/sequenceanalysis/pipeline/OrphanFilePipelineJob.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,8 @@
5757
import java.util.Map;
5858
import java.util.Set;
5959

60+
import static org.labkey.sequenceanalysis.pipeline.SequenceTaskHelper.SHARED_SUBFOLDER_NAME;
61+
6062
public class OrphanFilePipelineJob extends PipelineJob
6163
{
6264
// Default constructor for serialization
@@ -373,6 +375,16 @@ public void getOrphanFilesForContainer(Container c, User u, Set<File> orphanFile
373375
unexpectedPipelineDirs.add(subdir);
374376
}
375377

378+
File sharedDir = new File(subdir, SHARED_SUBFOLDER_NAME);
379+
if (sharedDir.exists())
380+
{
381+
long size = FileUtils.sizeOfDirectory(sharedDir);
382+
if (size > 1e6)
383+
{
384+
getJob().getLogger().warn("Large Shared folder: " + sharedDir.getPath());
385+
}
386+
}
387+
376388
getOrphanFilesForDirectory(knownExpDatas, dataMap, subdir, orphanFiles, orphanIndexes);
377389
}
378390
}

SequenceAnalysis/src/org/labkey/sequenceanalysis/pipeline/SequenceAlignmentTask.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -209,10 +209,6 @@ public WorkDirectory createWorkDirectory(String jobGUID, FileAnalysisJobSupport
209209
@Override
210210
public boolean isJobComplete(PipelineJob job)
211211
{
212-
FileAnalysisJobSupport support = (FileAnalysisJobSupport) job;
213-
String baseName = support.getBaseName();
214-
File dirAnalysis = support.getAnalysisDirectory();
215-
216212
return false;
217213
}
218214
}
@@ -469,6 +465,8 @@ else if (doCopy)
469465
actions.add(action);
470466

471467
referenceGenome.setWorkingFasta(new File(targetDir, refFasta.getName()));
468+
469+
getTaskFileManagerImpl().addIntermediateFile(targetDir);
472470
}
473471
catch (IOException e)
474472
{

0 commit comments

Comments
 (0)