fixed the conversion between scala and kotlin for ActionData in the tests 36/head
authorYaniv Rodenski <roadan@gmail.com>
Thu, 8 Nov 2018 23:20:35 +0000 (10:20 +1100)
committerYaniv Rodenski <roadan@gmail.com>
Thu, 8 Nov 2018 23:20:35 +0000 (10:20 +1100)
frameworks/spark/runner/src/test/scala/org/apache/amaterasu/utilities/TestNotifier.scala
leader/src/test/scala/org/apache/amaterasu/common/execution/ActionStatusTests.scala
leader/src/test/scala/org/apache/amaterasu/common/execution/JobExecutionTests.scala
leader/src/test/scala/org/apache/amaterasu/common/execution/JobParserTests.scala
leader/src/test/scala/org/apache/amaterasu/common/execution/JobRestoreTests.scala
leader/src/test/scala/org/apache/amaterasu/utilities/HttpServerTests.scala

index 16cb97b..430e75a 100644 (file)
@@ -20,7 +20,7 @@ import org.apache.amaterasu.common.execution.actions.Notifier
 import org.apache.amaterasu.common.logging.Logging
 
 
-class TestNotifier extends Notifier with Logging {
+class TestNotifier extends Notifier  {
 
   override def info(msg: String): Unit = {
     log.info(msg)
index af2c8ba..197c703 100755 (executable)
@@ -28,13 +28,15 @@ import org.apache.curator.test.TestingServer
 import org.apache.zookeeper.CreateMode
 import org.scalatest.{FlatSpec, Matchers}
 
+import scala.collection.JavaConverters._
+
 class ActionStatusTests extends FlatSpec with Matchers {
 
   // setting up a testing zookeeper server (curator TestServer)
   val retryPolicy = new ExponentialBackoffRetry(1000, 3)
   val server = new TestingServer(2181, true)
   val jobId = s"job_${System.currentTimeMillis}"
-  val data = new ActionData(ActionStatus.pending, "test_action", "start.scala", "spark","scala", null, new util.HashMap() , null)
+  val data = new ActionData(ActionStatus.pending, "test_action", "start.scala", "spark","scala", "0000001", new util.HashMap() , List[String]().asJava)
 
   "an Action" should "queue it's ActionData int the job queue when executed" in {
 
@@ -48,7 +50,7 @@ class ActionStatusTests extends FlatSpec with Matchers {
     val action = SequentialAction(data.getName, data.getSrc, data.getGroupId, data.getTypeId, Map.empty, jobId, queue, client, 1)
 
     action.execute()
-    queue.peek().getName() should be(data.getName)
+    queue.peek().getName should be(data.getName)
     queue.peek().getSrc should be(data.getSrc)
 
   }
index b15f0bd..ef47cc1 100755 (executable)
@@ -49,21 +49,21 @@ class JobExecutionTests extends FlatSpec with Matchers {
   "a job" should "queue the first action when the JobManager.start method is called " in {
 
     job.start
-    queue.peek.name should be ("start")
+    queue.peek.getName should be ("start")
 
     // making sure that the status is reflected in zk
-    val actionStatus = client.getData.forPath(s"/${jobId}/task-0000000000")
+    val actionStatus = client.getData.forPath(s"/$jobId/task-0000000000")
     new String(actionStatus) should be("queued")
 
   }
 
   it should "return the start action when calling getNextAction and dequeue it" in {
 
-    job.getNextActionData.name should be ("start")
+    job.getNextActionData.getName should be ("start")
     queue.size should be (0)
 
     // making sure that the status is reflected in zk
-    val actionStatus = client.getData.forPath(s"/${jobId}/task-0000000000")
+    val actionStatus = client.getData.forPath(s"/$jobId/task-0000000000")
     new String(actionStatus) should be("started")
 
   }
@@ -73,17 +73,17 @@ class JobExecutionTests extends FlatSpec with Matchers {
     job.actionComplete("0000000000")
 
     // making sure that the status is reflected in zk
-    val actionStatus = client.getData.forPath(s"/${jobId}/task-0000000000")
+    val actionStatus = client.getData.forPath(s"/$jobId/task-0000000000")
     new String(actionStatus) should be("complete")
 
   }
 
   "the next step2 job" should "be queued as a result of the completion" in {
 
-    queue.peek.name should be ("step2")
+    queue.peek.getName should be ("step2")
 
     // making sure that the status is reflected in zk
-    val actionStatus = client.getData.forPath(s"/${jobId}/task-0000000001")
+    val actionStatus = client.getData.forPath(s"/$jobId/task-0000000001")
     new String(actionStatus) should be("queued")
 
   }
@@ -92,20 +92,20 @@ class JobExecutionTests extends FlatSpec with Matchers {
 
     val data = job.getNextActionData
 
-    data.name should be ("step2")
+    data.getName should be ("step2")
 
     // making sure that the status is reflected in zk
-    val actionStatus = client.getData.forPath(s"/${jobId}/task-0000000001")
+    val actionStatus = client.getData.forPath(s"/$jobId/task-0000000001")
     new String(actionStatus) should be("started")
   }
 
   it should "be marked as failed when JobManager. is called" in {
 
     job.actionFailed("0000000001", "test failure")
-    queue.peek.name should be ("error-action")
+    queue.peek.getName should be ("error-action")
 
     // making sure that the status is reflected in zk
-    val actionStatus = client.getData.forPath(s"/${jobId}/task-0000000001-error")
+    val actionStatus = client.getData.forPath(s"/$jobId/task-0000000001-error")
     new String(actionStatus) should be("queued")
 
     // and returned by getNextActionData
index 3a347c1..13685f9 100755 (executable)
@@ -55,9 +55,9 @@ class JobParserTests extends FlatSpec with Matchers {
 
     job.registeredActions.size should be(3)
 
-    job.registeredActions.get("0000000000").get.data.name should be("start")
-    job.registeredActions.get("0000000001").get.data.name should be("step2")
-    job.registeredActions.get("0000000001-error").get.data.name should be("error-action")
+    job.registeredActions.get("0000000000").get.data.getName should be("start")
+    job.registeredActions.get("0000000001").get.data.getName should be("step2")
+    job.registeredActions.get("0000000001-error").get.data.getName should be("error-action")
 
   }
 
index eb08942..64887ab 100755 (executable)
@@ -68,7 +68,7 @@ class JobRestoreTests extends FlatSpec with Matchers with BeforeAndAfterEach {
 
     JobLoader.restoreJobState(manager, jobId, client)
 
-    queue.peek.name should be("start")
+    queue.peek.getName should be("start")
   }
 
   "a restored job" should "have all started actions in the executionQueue" in {
@@ -78,6 +78,6 @@ class JobRestoreTests extends FlatSpec with Matchers with BeforeAndAfterEach {
 
     JobLoader.restoreJobState(manager, jobId, client)
 
-    queue.peek.name should be("start")
+    queue.peek.getName should be("start")
   }
 }
\ No newline at end of file
index 0e321f0..7eba1da 100644 (file)
@@ -26,7 +26,7 @@ class HttpServerTests extends FlatSpec with Matchers {
 
   // this is an ugly hack, getClass.getResource("/").getPath should have worked but
   // stopped working when we moved to gradle :(
-  val resources = new File(getClass.getResource("/simple-maki.yml").getPath).getParent
+  val resources: String = new File(getClass.getResource("/simple-maki.yml").getPath).getParent
 
   //  "Jetty Web server" should "start HTTP server, serve content and stop successfully" in {
   //