start HTTP server on workflow run

hpratt · hpratt · commit 1f6d4a9df0d1 · 2023-10-25T19:20:17.000-04:00
diff --git a/src/main/kotlin/krews/core/WorkflowRunner.kt b/src/main/kotlin/krews/core/WorkflowRunner.kt
@@ -52,8 +52,6 @@ class WorkflowRunner(
         runRepo = RunRepo(runDb)
         val reportThreadFactory = BasicThreadFactory.Builder().namingPattern("report-gen-%d").build()
         reportPool = Executors.newSingleThreadScheduledExecutor(reportThreadFactory)
-
-        if (httpPort != null) runHTTPServer(httpPort)
     }
 
     fun run() {
@@ -73,6 +71,7 @@ class WorkflowRunner(
             }
         }, reportGenerationDelay, reportGenerationDelay, TimeUnit.SECONDS)
 
+        if (httpPort != null) runHTTPServer(httpPort)
         val workflowRunSuccessful = runWorkflow()
 
         runRepo.completeWorkflowRun(workflowRun, workflowRunSuccessful)

Original file line number	Diff line number	Diff line change
`@@ -52,8 +52,6 @@ class WorkflowRunner(`
`52`	`52`	`runRepo = RunRepo(runDb)`
`53`	`53`	`val reportThreadFactory = BasicThreadFactory.Builder().namingPattern("report-gen-%d").build()`
`54`	`54`	`reportPool = Executors.newSingleThreadScheduledExecutor(reportThreadFactory)`
`55`		`-`
`56`		`- if (httpPort != null) runHTTPServer(httpPort)`
`57`	`55`	`}`
`58`	`56`
`59`	`57`	`fun run() {`
`@@ -73,6 +71,7 @@ class WorkflowRunner(`
`73`	`71`	`}`
`74`	`72`	`}, reportGenerationDelay, reportGenerationDelay, TimeUnit.SECONDS)`
`75`	`73`
	`74`	`+ if (httpPort != null) runHTTPServer(httpPort)`
`76`	`75`	`val workflowRunSuccessful = runWorkflow()`
`77`	`76`
`78`	`77`	`runRepo.completeWorkflowRun(workflowRun, workflowRunSuccessful)`