Switch up execution contexts slightly

lucidsoftware · Jul 7, 2024 · 99c7318 · 99c7318
1 parent 3d71a3c
commit 99c7318
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/scala/higherkindness/rules_scala/common/worker/WorkerMain.scala b/src/main/scala/higherkindness/rules_scala/common/worker/WorkerMain.scala
@@ -36,7 +36,7 @@ trait WorkerMain[S] {
           exceptionHandler,
           false,
         )
-        implicit val ec = ExecutionContext.fromExecutor(fjp)
+        val ec = ExecutionContext.fromExecutor(fjp)
 
         System.setIn(new ByteArrayInputStream(Array.emptyByteArray))
         System.setOut(System.err)
@@ -74,7 +74,7 @@ trait WorkerMain[S] {
               } catch {
                 case AnnexWorkerError(code, _, _) => code
               }
-            }
+            }(ec)
 
             f.onComplete {
               case Success(code) => {
@@ -89,7 +89,7 @@ trait WorkerMain[S] {
                 System.err.println(s"Uncaught exception in Future while proccessing WorkRequest $requestId:")
                 e.printStackTrace(System.err)
               }
-            }
+            }(scala.concurrent.ExecutionContext.global)
             process(ctx)
           }
           process(init(Some(args.toArray)))