Commit b747862a authored by Peter van 't Hof's avatar Peter van 't Hof

Fixed small issue with dependency

parent 8242e484
......@@ -141,7 +141,7 @@ object WriteDependencies extends Logging with Configurable {
val jobsDeps = jobs.map(x => x._1 -> (x._2("depends_on_jobs") match {
case l: List[_] => l.map(_.toString)
case _ => throw new IllegalStateException("Value 'depends_on_jobs' is not a list")
case _ => throw new IllegalStateException("Value 'depends_on_jobs' is not a list")
}))
val jobsWriter = new PrintWriter(new File(outputDir, s"$prefix.jobs.json"))
jobsWriter.println(ConfigUtils.mapToJson(jobsDeps).spaces2)
......
......@@ -57,12 +57,12 @@ class WriteSummary(val root: Configurable) extends InProcessFunction with Config
for (q <- qscript.summaryQScripts)
deps :+= q.summaryFile
for ((_, l) <- qscript.summarizables; s <- l) s match {
case f: QFunction => try {
case f: QFunction if qscript.functions.contains(f) => try {
deps :+= f.firstOutput
} catch {
} catch {
case e: NullPointerException => logger.warn("Queue values are not init")
}
case _ =>
case _ =>
}
jobOutputFile = new File(out.getParentFile, ".%s.%s.out".format(out.getName, analysisName))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment