diff options
| -rw-r--r-- | src/main/scala/com/ibm/ToreeClient.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/scala/com/ibm/ToreeClient.scala b/src/main/scala/com/ibm/ToreeClient.scala index d21d419..d1a8904 100644 --- a/src/main/scala/com/ibm/ToreeClient.scala +++ b/src/main/scala/com/ibm/ToreeClient.scala @@ -46,7 +46,9 @@ class ToreeGateway(client: SparkKernelClient) { private def handleSuccess(promise:Promise[String], executeReplyOk: ExecuteReplyOk) = { log.warn(s"Successful code completion") - promise.complete(Try("done")) + if(! promise.isCompleted) { + promise.complete(Try("done")) + } } private def handleError(promise:Promise[String], reply:ExecuteReplyError) { |