diff options
| author | Luciano Resende <lresende@apache.org> | 2017-01-17 22:27:55 -0800 |
|---|---|---|
| committer | Luciano Resende <lresende@apache.org> | 2017-01-17 22:27:55 -0800 |
| commit | 88da39c7713b36b2b9dfe4ce88cba1aeabd9064d (patch) | |
| tree | e52e1dbc9a0275d197dbd1084fa1353d149a3cc0 | |
| parent | d5d6ced608ceeb5672201e63ff2df63b735206ee (diff) | |
| download | toree-gateway-88da39c7713b36b2b9dfe4ce88cba1aeabd9064d.tar.gz toree-gateway-88da39c7713b36b2b9dfe4ce88cba1aeabd9064d.tar.bz2 toree-gateway-88da39c7713b36b2b9dfe4ce88cba1aeabd9064d.zip | |
Process isCompleted only when promise is not completed yet
| -rw-r--r-- | src/main/scala/com/ibm/ToreeGateway.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/scala/com/ibm/ToreeGateway.scala b/src/main/scala/com/ibm/ToreeGateway.scala index edaa1e2..a27e0bb 100644 --- a/src/main/scala/com/ibm/ToreeGateway.scala +++ b/src/main/scala/com/ibm/ToreeGateway.scala @@ -45,8 +45,8 @@ class ToreeGateway(client: SparkKernelClient) { } private def handleSuccess(promise:Promise[String], executeReplyOk: ExecuteReplyOk) = { - log.warn(s"Successful code completion") if(! promise.isCompleted) { + log.warn(s"Successful code completion") promise.complete(Try("done")) } } |