revert worker pool dispatch change for dev testing

VEuPathDB · Apr 19, 2024 · 01c9c50 · 01c9c50
1 parent c1e56ce
commit 01c9c50
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/components/async/src/main/kotlin/vdi/component/async/WorkerPool.kt b/components/async/src/main/kotlin/vdi/component/async/WorkerPool.kt
@@ -24,7 +24,8 @@ class WorkerPool(
   fun start() {
     log.info("starting worker pool $name with queue size $jobQueueSize and worker count $workerCount")
 
-    runBlocking(Dispatchers.IO) {
+//    runBlocking(Dispatchers.IO) {
+    runBlocking {
       repeat(workerCount) { i ->
         val j = i + 1
         launch (CoroutineThreadContext(contextData = ThreadContextData(map = mapOf("workerID" to "$name-$j"), Stack()))) {

diff --git a/daemons/event-router/src/main/kotlin/vdi/daemon/events/routing/model/MinIOEventRecord.kt b/daemons/event-router/src/main/kotlin/vdi/daemon/events/routing/model/MinIOEventRecord.kt
@@ -23,7 +23,7 @@ data class MinIOEventRecord(
   val userIdentity: MinIOEventUserIdentity,
 
   @JsonProperty("requestParameters")
-  val requestParameters: Map<String, String>,
+  val requestParameters: Map<String, String>?,
 
   @JsonProperty("responseElements")
   val responseElements: Map<String, String>,

diff --git a/startup.sh b/startup.sh
@@ -16,4 +16,4 @@ waitFor cache-db cache-db 5432
 waitFor rabbit "$GLOBAL_RABBIT_HOST" "${GLOBAL_RABBIT_PORT:-5672}"
 waitFor minio "$S3_HOST" "$S3_PORT"
 
-exec java -jar -XX:+CrashOnOutOfMemoryError $JVM_MEM_ARGS $JVM_ARGS -Djdk.httpclient.HttpClient.log=errors,headers /service.jar
+exec java -jar -XX:+CrashOnOutOfMemoryError $JVM_MEM_ARGS $JVM_ARGS -Djdk.httpclient.HttpClient.log=errors,headers /service.jar