From 88da39c7713b36b2b9dfe4ce88cba1aeabd9064d Mon Sep 17 00:00:00 2001 From: Luciano Resende Date: Tue, 17 Jan 2017 22:27:55 -0800 Subject: Process isCompleted only when promise is not completed yet --- src/main/scala/com/ibm/ToreeGateway.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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")) } } -- cgit v1.2.3