Skip to content

Commit 1e60cae

Browse files
committed
Reset job errors before submitting to the cluster
1 parent bf37590 commit 1e60cae

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

SequenceAnalysis/src/org/labkey/sequenceanalysis/run/analysis/MergeLoFreqVcfHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -721,7 +721,7 @@ private void runSnpEff(JobContext ctx, Map<String, SiteAndAlleles> siteToAllele,
721721
}
722722

723723
File snpEffBaseDir = SNPEffStep.checkOrCreateIndex(ctx.getSequenceSupport(), ctx.getLogger(), genome, geneFileId);
724-
File outputVcfSnpEff = new File(ctx.getOutputDir(), basename + ".snpeff.vcf.gz");
724+
File outputVcfSnpEff = new File(ctx.getOutputDir(), basename + "snpeff.vcf.gz");
725725
snpEffWrapper.runSnpEff(genome.getGenomeId(), geneFileId, snpEffBaseDir, vcfOut, outputVcfSnpEff, null);
726726
}
727727
}

cluster/src/org/labkey/cluster/pipeline/AbstractClusterExecutionEngine.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -373,6 +373,10 @@ else if (j.getClusterId() == null)
373373
private boolean doSubmitJobToCluster(ClusterJob j, PipelineJob job) throws PipelineJobException
374374
{
375375
boolean success = false;
376+
377+
//NOTE: clear errors, since a previously failed/retried job will have non-zero errors
378+
job.setErrors(0);
379+
376380
List<String> ret = submitJobToCluster(j, job);
377381
if (j.getClusterId() != null)
378382
{

0 commit comments

Comments
 (0)