Skip to content

Commit

Permalink
Spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
niloc132 committed Dec 14, 2023
1 parent 48fa48b commit 4cb9e0c
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down Expand Up @@ -343,6 +343,7 @@ interface PythonScriptSessionModule extends Closeable {

interface PythonDeephavenThreadsModule extends Closeable {
void close();

void _register_named_java_executor(String executorName, Consumer<Runnable> execute);
}
}

0 comments on commit 4cb9e0c

Please sign in to comment.