From 4cb9e0cffe830b4c370a4102b8a54f3ebbf9e015 Mon Sep 17 00:00:00 2001 From: Colin Alworth <colinalworth@deephaven.io> Date: Thu, 14 Dec 2023 11:15:29 -0600 Subject: [PATCH] Spotless --- .../deephaven/integrations/python/PythonDeephavenSession.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/Integrations/src/main/java/io/deephaven/integrations/python/PythonDeephavenSession.java b/Integrations/src/main/java/io/deephaven/integrations/python/PythonDeephavenSession.java index 817a4721aa3..c1cc8a457e3 100644 --- a/Integrations/src/main/java/io/deephaven/integrations/python/PythonDeephavenSession.java +++ b/Integrations/src/main/java/io/deephaven/integrations/python/PythonDeephavenSession.java @@ -131,7 +131,7 @@ public PythonDeephavenSession( private void registerJavaExecutor() { // TODO (deephaven-core#4040) Temporary exec service until we have cleaner startup wiring try (PyModule pyModule = PyModule.importModule("deephaven.server.executors"); - final PythonDeephavenThreadsModule module = pyModule.createProxy(PythonDeephavenThreadsModule.class)) { + final PythonDeephavenThreadsModule module = pyModule.createProxy(PythonDeephavenThreadsModule.class)) { ExecutorService executorService = Executors.newFixedThreadPool(1); module._register_named_java_executor("serial", executorService::submit); module._register_named_java_executor("concurrent", executorService::submit); @@ -343,6 +343,7 @@ interface PythonScriptSessionModule extends Closeable { interface PythonDeephavenThreadsModule extends Closeable { void close(); + void _register_named_java_executor(String executorName, Consumer<Runnable> execute); } }