@@ -71,10 +71,20 @@ public void processFilesOnWebserver(PipelineJob job, SequenceAnalysisJobSupport
7171 @ Override
7272 public void processFilesRemote (List <SequenceOutputFile > inputFiles , JobContext ctx ) throws UnsupportedOperationException , PipelineJobException
7373 {
74- File inputVCF = ctx .getSequenceSupport (). getCachedData ( ctx . getParams ().getInt ("svVCF" ) );
75- if (! inputVCF . exists () )
74+ int svVcfId = ctx .getParams ().optInt ("svVCF" , 0 );
75+ if (svVcfId == 0 )
7676 {
77- throw new PipelineJobException ("Unable to find file: " + inputVCF .getPath ());
77+ throw new PipelineJobException ("svVCF param was null" );
78+ }
79+
80+ File svVcf = ctx .getSequenceSupport ().getCachedData (svVcfId );
81+ if (svVcf == null )
82+ {
83+ throw new PipelineJobException ("File not found for ID: " + svVcfId );
84+ }
85+ else if (!svVcf .exists ())
86+ {
87+ throw new PipelineJobException ("Missing file: " + svVcf .getPath ());
7888 }
7989
8090 Integer threads = SequencePipelineService .get ().getMaxThreads (ctx .getLogger ());
@@ -117,22 +127,6 @@ public void processFilesRemote(List<SequenceOutputFile> inputFiles, JobContext c
117127 paragraphArgs .add ("-o" );
118128 paragraphArgs .add (paragraphOut .getPath ());
119129
120- int svVcfId = ctx .getParams ().optInt ("svVCF" );
121- if (svVcfId == 0 )
122- {
123- throw new PipelineJobException ("Missing svVCF ID" );
124- }
125-
126- File svVcf = ctx .getSequenceSupport ().getCachedData (svVcfId );
127- if (svVcf == null )
128- {
129- throw new PipelineJobException ("File not found for ID: " + svVcfId );
130- }
131- else if (!svVcf .exists ())
132- {
133- throw new PipelineJobException ("Missing file: " + svVcf .getPath ());
134- }
135-
136130 paragraphArgs .add ("-i" );
137131 paragraphArgs .add (svVcf .getPath ());
138132
0 commit comments