diff options
-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")) } } |