@@ -41,6 +41,7 @@ private class ThreadSession(val id: String, session: com.cloudera.hue.livy.repl.
case repl.Session.Busy() => Busy()
case repl.Session.ShuttingDown() => Dead()
case repl.Session.ShutDown() => Dead()
+ case repl.Session.Error() => Error()
}
@@ -94,6 +94,10 @@ class WebSession(val id: String) extends Session with Logging {
Unit
+ case NotStarted() =>
+ Future {
+ waitForStateChangeFrom(NotStarted(), { stop() })
+ }
case Starting() =>
Future {
waitForStateChangeFrom(Starting(), { stop() })