@@ -93,15 +93,15 @@ private static File convertInput(File f)
9393 return AbstractGenomicsDBImportHandler .TILE_DB_FILETYPE .isType (f ) ? f .getParentFile () : f ;
9494 }
9595
96- public static List <File > copyVcfsLocally (SequenceOutputHandler .JobContext ctx , Collection <File > inputGVCFs , Collection <File > toDelete , boolean isResume ) throws PipelineJobException
96+ public static List <File > copyVcfsLocally (SequenceOutputHandler .JobContext ctx , Collection <File > inputFiles , Collection <File > toDelete , boolean isResume ) throws PipelineJobException
9797 {
9898 try
9999 {
100100 //Note: because we cannot be certain names are unique, inspect:
101101 HashMap <File , String > inputToDest = new LinkedHashMap <>();
102102 Set <String > uniqueDestNames = new CaseInsensitiveHashSet ();
103103
104- inputGVCFs .forEach (x -> {
104+ inputFiles .forEach (x -> {
105105 x = convertInput (x );
106106 String fn = x .getName ();
107107
@@ -146,12 +146,12 @@ public static List<File> copyVcfsLocally(SequenceOutputHandler.JobContext ctx, C
146146 List <File > vcfsToProcess = new ArrayList <>();
147147 int totalExisting = 0 ;
148148 int idx = 0 ;
149- for (File f : inputGVCFs )
149+ for (File f : inputFiles )
150150 {
151151 idx ++;
152152 if (idx % 100 == 0 )
153153 {
154- ctx .getLogger ().info ("Inspected file " + idx + " of " + inputGVCFs .size ());
154+ ctx .getLogger ().info ("Inspected file " + idx + " of " + inputFiles .size ());
155155 }
156156
157157 f = convertInput (f );
@@ -247,7 +247,7 @@ else if (f.isDirectory() && doneFile.exists())
247247 vcfsToProcess .add (movedFile );
248248 }
249249
250- ctx .getLogger ().debug ("Total pre-existing inputs that were re-used: " + totalExisting );
250+ ctx .getLogger ().debug ("Total pre-existing inputs that were re-used: " + totalExisting + " of " + inputFiles . size () );
251251
252252 return vcfsToProcess ;
253253 }
0 commit comments