From 3b053a66ff97c1e29ec8b0233562d7bdf92db2ca Mon Sep 17 00:00:00 2001
From: Gian Merlino <gianmerlino@gmail.com>
Date: Fri, 13 Dec 2013 07:47:18 -0800
Subject: [PATCH] TaskLifecycleTest: Add test for never-ready task

---
 .../druid/indexing/overlord/TaskLifecycleTest.java | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLifecycleTest.java b/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLifecycleTest.java
index 910b0c04e36..5f80f37d132 100644
--- a/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLifecycleTest.java
+++ b/indexing-service/src/test/java/io/druid/indexing/overlord/TaskLifecycleTest.java
@@ -293,6 +293,20 @@ public class TaskLifecycleTest
     Assert.assertEquals("num segments nuked", 0, mdc.getNuked().size());
   }
 
+  @Test
+  public void testNeverReadyTask() throws Exception
+  {
+    final Task neverReadyTask = new DefaultObjectMapper().readValue(
+        "{\"type\":\"noop\", \"isReadyResult\":\"exception\"}\"",
+        Task.class
+    );
+    final TaskStatus status = runTask(neverReadyTask);
+
+    Assert.assertEquals("statusCode", TaskStatus.Status.FAILED, status.getStatusCode());
+    Assert.assertEquals("num segments published", 0, mdc.getPublished().size());
+    Assert.assertEquals("num segments nuked", 0, mdc.getNuked().size());
+  }
+
   @Test
   public void testSimple() throws Exception
   {