Commit 15a872aa authored by Peter van 't Hof's avatar Peter van 't Hof
Browse files

Disable svg for now

parent 3145f6f4
...@@ -115,9 +115,10 @@ object PipelineStatus extends ToolCommand { ...@@ -115,9 +115,10 @@ object PipelineStatus extends ToolCommand {
val totalFailed = jobFailed.size val totalFailed = jobFailed.size
val totalPending = totalJobs - jobsStart.size - jobDone.size - jobFailed.size val totalPending = totalJobs - jobsStart.size - jobDone.size - jobFailed.size
futures.foreach(x => Await.ready(x, Duration.Inf))
logger.info(s"Total job: ${totalJobs}, Pending: ${totalPending}, Ready to run / running: ${totalStart}, Done: ${totalDone}, Failed ${totalFailed}") logger.info(s"Total job: ${totalJobs}, Pending: ${totalPending}, Ready to run / running: ${totalStart}, Done: ${totalDone}, Failed ${totalFailed}")
futures.foreach(x => Await.ready(x, Duration.Inf))
if (follow) { if (follow) {
Thread.sleep(refreshTime * 1000) Thread.sleep(refreshTime * 1000)
writePipelineStatus(deps, outputDir, jobDone, jobFailed, follow) writePipelineStatus(deps, outputDir, jobDone, jobFailed, follow)
...@@ -155,7 +156,7 @@ object PipelineStatus extends ToolCommand { ...@@ -155,7 +156,7 @@ object PipelineStatus extends ToolCommand {
jobFailed: Set[String], jobFailed: Set[String],
jobsStart: Set[String], jobsStart: Set[String],
deps: Deps, deps: Deps,
plots: Boolean): Future[Unit] = Future { png: Boolean = true, svg: Boolean = false): Future[Unit] = Future {
val writer = new PrintWriter(outputFile) val writer = new PrintWriter(outputFile)
writer.println("digraph graphname {") writer.println("digraph graphname {")
jobDone jobDone
...@@ -176,12 +177,12 @@ object PipelineStatus extends ToolCommand { ...@@ -176,12 +177,12 @@ object PipelineStatus extends ToolCommand {
writer.println("}") writer.println("}")
writer.close() writer.close()
writeGvToPlot(outputFile) writeGvToPlot(outputFile, png, svg)
} }
def writeGvToPlot(input: File): Unit = { def writeGvToPlot(input: File, png: Boolean = true, svg: Boolean = true): Unit = {
Process(Seq("dot", "-Tpng", "-O", input.getAbsolutePath)).run() if (png) Process(Seq("dot", "-Tpng", "-O", input.getAbsolutePath)).run().exitValue()
Process(Seq("dot", "-Tsvg", "-O", input.getAbsolutePath)).run() if (svg) Process(Seq("dot", "-Tsvg", "-O", input.getAbsolutePath)).run().exitValue()
} }
def jobsReadyStart(deps: Deps, jobsDone: Set[String]): Set[String] = { def jobsReadyStart(deps: Deps, jobsDone: Set[String]): Set[String] = {
......
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