From d68c9570dd3e951568476892a1eefafd71ad1399 Mon Sep 17 00:00:00 2001
From: Paul Houle <paul@ontology2.com>
Date: Thu, 16 Jan 2014 14:49:59 -0500
Subject: [PATCH] #28 --  implement poller for step state instead of job state

---
 .idea/workspace.xml                           | 38 ++++++++++---------
 .../ontology2/haruhi/PersistentCluster.java   |  1 -
 2 files changed, 21 insertions(+), 18 deletions(-)

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 33e13f7..081b7b0 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -156,10 +156,10 @@
       <content type="file-editors">
         <state>
           <leaf>
-            <file leaf-file-name="PersistentCluster.java" pinned="false" current="false" current-in-tab="true">
+            <file leaf-file-name="PersistentCluster.java" pinned="false" current="true" current-in-tab="true">
               <entry file="file://$PROJECT_DIR$/haruhi/src/main/java/com/ontology2/haruhi/PersistentCluster.java">
                 <provider selected="true" editor-type-id="text-editor">
-                  <state line="102" column="27" selection-start="3991" selection-end="3991" vertical-scroll-proportion="0.60808706" vertical-offset="952" max-vertical-offset="2482">
+                  <state line="101" column="57" selection-start="3963" selection-end="3963" vertical-scroll-proportion="0.60808706" vertical-offset="935" max-vertical-offset="2465">
                     <folding>
                       <element signature="imports" expanded="true" />
                       <element signature="e#3478#3709#0" expanded="true" />
@@ -198,7 +198,7 @@
           </provider>
         </entry>
       </file>
-      <file leaf-file-name="MavenManagedJar.java" pinned="false" current="true" current-in-tab="true">
+      <file leaf-file-name="MavenManagedJar.java" pinned="false" current="false" current-in-tab="true">
         <entry file="file://$PROJECT_DIR$/haruhi/src/main/java/com/ontology2/haruhi/MavenManagedJar.java">
           <provider selected="true" editor-type-id="text-editor">
             <state line="22" column="1" selection-start="507" selection-end="507" vertical-scroll-proportion="0.3637931" vertical-offset="44" max-vertical-offset="1275">
@@ -362,8 +362,8 @@
     </treeState>
   </component>
   <component name="ProjectFrameBounds">
-    <option name="x" value="1045" />
-    <option name="y" value="531" />
+    <option name="x" value="50" />
+    <option name="y" value="407" />
     <option name="width" value="1024" />
     <option name="height" value="1215" />
   </component>
@@ -1500,11 +1500,15 @@
       <created>1389900499667</created>
       <updated>1389900499667</updated>
     </task>
-    <option name="localTasksCounter" value="99" />
+    <task id="LOCAL-00099" summary="#28 --  implement poller for step state instead of job state&#10;">
+      <created>1389901763040</created>
+      <updated>1389901763040</updated>
+    </task>
+    <option name="localTasksCounter" value="100" />
     <servers />
   </component>
   <component name="ToolWindowManager">
-    <frame x="1045" y="531" width="1024" height="1215" extended-state="0" />
+    <frame x="50" y="407" width="1024" height="1215" extended-state="0" />
     <editor active="true" />
     <layout>
       <window_info id="Palette&#9;" active="false" anchor="left" auto_hide="false" internal_type="DOCKED" type="DOCKED" visible="false" weight="0.33" sideWeight="0.5" order="2" side_tool="false" content_ui="tabs" />
@@ -1546,7 +1550,6 @@
       <TodoPanelSettings />
     </option>
     <option name="CHECK_COMMIT_MESSAGE_SPELLING" value="false" />
-    <MESSAGE value="#92 -- more logging code" />
     <MESSAGE value="#92 -- copy the Text objects that we're storing because I'm pretty sure now we're getting hung up because Hadoop is reusing Writables so they are not safe to store in a collection" />
     <MESSAGE value="#92 -- correct name of m1XLargeX2AwsCluster and add m1XLargeX5AwsCluster&#10;" />
     <MESSAGE value="resolve #96 by introducing RecyclingIterable&lt;T&gt;;  also resolve #97 to bump spring and centipede versions&#10;" />
@@ -1571,7 +1574,8 @@
     <MESSAGE value="#28 --  but I've got to wire up the EMR client and S3 information..." />
     <MESSAGE value="#28 --  check environment variable and hopefully delay long enough that we don't see the cluster in the initial WAITING state&#10;" />
     <MESSAGE value="#28 --  implement poller for step state instead of job state" />
-    <option name="LAST_COMMIT_MESSAGE" value="#28 --  implement poller for step state instead of job state" />
+    <MESSAGE value="#28 --  implement poller for step state instead of job state&#10;" />
+    <option name="LAST_COMMIT_MESSAGE" value="#28 --  implement poller for step state instead of job state&#10;" />
   </component>
   <component name="XDebuggerManager">
     <breakpoint-manager>
@@ -1862,9 +1866,16 @@
         </state>
       </provider>
     </entry>
+    <entry file="file://$PROJECT_DIR$/haruhi/src/main/java/com/ontology2/haruhi/MavenManagedJar.java">
+      <provider selected="true" editor-type-id="text-editor">
+        <state line="22" column="1" selection-start="507" selection-end="507" vertical-scroll-proportion="0.3637931" vertical-offset="44" max-vertical-offset="1275">
+          <folding />
+        </state>
+      </provider>
+    </entry>
     <entry file="file://$PROJECT_DIR$/haruhi/src/main/java/com/ontology2/haruhi/PersistentCluster.java">
       <provider selected="true" editor-type-id="text-editor">
-        <state line="102" column="27" selection-start="3991" selection-end="3991" vertical-scroll-proportion="0.60808706" vertical-offset="952" max-vertical-offset="2482">
+        <state line="101" column="57" selection-start="3963" selection-end="3963" vertical-scroll-proportion="0.60808706" vertical-offset="935" max-vertical-offset="2465">
           <folding>
             <element signature="imports" expanded="true" />
             <element signature="e#3478#3709#0" expanded="true" />
@@ -1873,13 +1884,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/haruhi/src/main/java/com/ontology2/haruhi/MavenManagedJar.java">
-      <provider selected="true" editor-type-id="text-editor">
-        <state line="22" column="1" selection-start="507" selection-end="507" vertical-scroll-proportion="0.3637931" vertical-offset="44" max-vertical-offset="1275">
-          <folding />
-        </state>
-      </provider>
-    </entry>
   </component>
 </project>
 
diff --git a/haruhi/src/main/java/com/ontology2/haruhi/PersistentCluster.java b/haruhi/src/main/java/com/ontology2/haruhi/PersistentCluster.java
index a48b899..0e7aef8 100644
--- a/haruhi/src/main/java/com/ontology2/haruhi/PersistentCluster.java
+++ b/haruhi/src/main/java/com/ontology2/haruhi/PersistentCluster.java
@@ -100,7 +100,6 @@ public boolean apply(@Nullable StepDetail input) {
             } else {
                 stepStatus=detail.getExecutionStatusDetail();
                 stepState=stepStatus.getState().intern();
-                stepStatus.
                 if (stepState!="PENDING" && stepState!="RUNNING") {
                     break;
                 }