You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@toree.apache.org by lr...@apache.org on 2017/02/19 09:37:02 UTC
[06/14] incubator-toree git commit: fire allInterpretersReady and
preRunCell events
fire allInterpretersReady and preRunCell events
allInterpretersReady event: fired when all interpreters have completed
their initialization
preRunCell event: fired every time a new cell is being run, unless the
silent flag is set
Project: http://git-wip-us.apache.org/repos/asf/incubator-toree/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-toree/commit/5feb3bda
Tree: http://git-wip-us.apache.org/repos/asf/incubator-toree/tree/5feb3bda
Diff: http://git-wip-us.apache.org/repos/asf/incubator-toree/diff/5feb3bda
Branch: refs/heads/sandbox
Commit: 5feb3bda115b8c900aeed7014108a390fd0cbb3b
Parents: 70b804b
Author: David Taieb <da...@us.ibm.com>
Authored: Tue Jan 17 18:13:40 2017 -0500
Committer: David Taieb <da...@us.ibm.com>
Committed: Tue Jan 17 18:13:40 2017 -0500
----------------------------------------------------------------------
.../org/apache/toree/boot/layer/ComponentInitialization.scala | 2 ++
.../kernel/protocol/v5/handler/ExecuteRequestHandler.scala | 5 +++++
2 files changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-toree/blob/5feb3bda/kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala
----------------------------------------------------------------------
diff --git a/kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala b/kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala
index ec05898..fafbae7 100644
--- a/kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala
+++ b/kernel/src/main/scala/org/apache/toree/boot/layer/ComponentInitialization.scala
@@ -88,6 +88,8 @@ trait StandardComponentInitialization extends ComponentInitialization {
initializeSparkContext(config, kernel, appName)
interpreterManager.initializeInterpreters(kernel)
+
+ pluginManager.fireEvent("allInterpretersReady")
val responseMap = initializeResponseMap()
http://git-wip-us.apache.org/repos/asf/incubator-toree/blob/5feb3bda/kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/ExecuteRequestHandler.scala
----------------------------------------------------------------------
diff --git a/kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/ExecuteRequestHandler.scala b/kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/ExecuteRequestHandler.scala
index 8060b41..3764b8c 100644
--- a/kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/ExecuteRequestHandler.scala
+++ b/kernel/src/main/scala/org/apache/toree/kernel/protocol/v5/handler/ExecuteRequestHandler.scala
@@ -74,6 +74,11 @@ class ExecuteRequestHandler(
actorLoader.load(SystemActorType.ExecuteRequestRelay),
(executeRequest, km, outputStream)
).mapTo[(ExecuteReply, ExecuteResult)]
+
+ if (!executeRequest.silent){
+ import org.apache.toree.plugins.Implicits._
+ kernel.pluginManager.fireEvent("preRunCell", "outputStream" -> outputStream)
+ }
// Flush the output stream after code execution completes to ensure
// stream messages are sent prior to idle status messages.