summaryrefslogtreecommitdiff
path: root/opendc-web/opendc-web-runner-quarkus/src
diff options
context:
space:
mode:
Diffstat (limited to 'opendc-web/opendc-web-runner-quarkus/src')
-rw-r--r--opendc-web/opendc-web-runner-quarkus/src/main/java/org/opendc/web/runner/runtime/OpenDCRunnerRecorder.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/opendc-web/opendc-web-runner-quarkus/src/main/java/org/opendc/web/runner/runtime/OpenDCRunnerRecorder.java b/opendc-web/opendc-web-runner-quarkus/src/main/java/org/opendc/web/runner/runtime/OpenDCRunnerRecorder.java
index c1f356bc..eccc8dcf 100644
--- a/opendc-web/opendc-web-runner-quarkus/src/main/java/org/opendc/web/runner/runtime/OpenDCRunnerRecorder.java
+++ b/opendc-web/opendc-web-runner-quarkus/src/main/java/org/opendc/web/runner/runtime/OpenDCRunnerRecorder.java
@@ -27,6 +27,7 @@ import io.quarkus.runtime.ShutdownContext;
import io.quarkus.runtime.annotations.Recorder;
import org.jboss.logging.Logger;
import org.opendc.web.client.runner.OpenDCRunnerClient;
+import org.opendc.web.runner.JobManager;
import org.opendc.web.runner.OpenDCRunner;
import java.io.File;
@@ -54,7 +55,7 @@ public class OpenDCRunnerRecorder {
OpenDCRunnerClient client = new OpenDCRunnerClient(apiUrl, null);
OpenDCRunner runner = new OpenDCRunner(
- client,
+ JobManager.create(client),
new File(config.tracePath),
parallelism,
config.jobTimeout,
@@ -77,7 +78,7 @@ public class OpenDCRunnerRecorder {
Thread thread = new Thread(() -> {
try {
// Wait for some time to allow Vert.x to bind to the local port
- Thread.sleep(1000);
+ Thread.sleep(4000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}