Repository: tinkerpop Updated Branches: refs/heads/TINKERPOP-786 512c66aea -> d70043e6f (forced update)
TINKERPOP-1671 Propagate exception to Future instead of calling thread Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/632c2090 Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/632c2090 Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/632c2090 Branch: refs/heads/TINKERPOP-786 Commit: 632c209026d4f7c3475f99a4ae7bba0942d2182d Parents: 3de9423 Author: Andrew Tolbert <[email protected]> Authored: Thu Apr 27 22:39:53 2017 -0500 Committer: Stephen Mallette <[email protected]> Committed: Mon May 8 14:36:31 2017 -0400 ---------------------------------------------------------------------- .../tinkerpop/gremlin/process/remote/RemoteConnection.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/632c2090/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/remote/RemoteConnection.java ---------------------------------------------------------------------- diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/remote/RemoteConnection.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/remote/RemoteConnection.java index 1831276..048df1e 100644 --- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/remote/RemoteConnection.java +++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/remote/RemoteConnection.java @@ -67,7 +67,11 @@ public interface RemoteConnection extends AutoCloseable { // default implementation for backward compatibility to 3.2.4 - this method will probably just become // the new submit() in 3.3.x when the deprecation is removed final CompletableFuture<RemoteTraversal<?, E>> promise = new CompletableFuture<>(); - promise.complete(submit(bytecode)); + try { + promise.complete(submit(bytecode)); + } catch (Exception t) { + promise.completeExceptionally(t); + } return promise; } }
