Ifwe

.jenkins/jobs/suite.dsl.groovy

@@ -0,0 +1,47 @@
+@GrabResolver('https://artifactory.tagged.com/artifactory/libs-release-local/')
+@Grab('com.tagged.build:jenkins-dsl-common:[0.1.0,)')
+
+import com.tagged.build.scm.*
+import com.tagged.build.common.*
+
+def satisfaction = new Project(
+    jobFactory,
+    [
+        scm: new StashSCM(project: "hadoop", name: "satisfaction-limbo"),
+        hipchatRoom: 'Cluster Corner',
+        email: '[email protected]',
+    ]
+).basicJob {
+    description "Satisfaction Scheduler"
+    label "scala"
+    jdk "jdk 7u51"
+    steps {
+        sbt('sbt',
+            '\'project satisfaction-core\' clean publish',
+            '-Dsbt.log.noformat=true',
+            '-Xmx1536M -Xss1M -XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m')
+        sbt('sbt',
+            '\'project satisfaction-engine\' clean publish',
+            '-Dsbt.log.noformat=true',
+            '-Xmx1536M -Xss1M -XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m')
+        sbt('sbt',
+            '\'project satisfaction-hadoop\' clean publish',
+            '-Dsbt.log.noformat=true',
+            '-Xmx1536M -Xss1M -XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m')
+        sbt('sbt',
+            '\'project satisfaction-hive\' clean publish',
+            '-Dsbt.log.noformat=true',
+            '-Xmx1536M -Xss1M -XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m')
+        sbt('sbt',
+            '\'project satisfaction-hive-ms\' clean publish',
+            '-Dsbt.log.noformat=true',
+            '-Xmx1536M -Xss1M -XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m')
+        sbt('sbt',
+            '\'project willrogers\' package rpm:packageBin',
+            '-Dsbt.log.noformat=true',
+            '-Xmx1536M -Xss1M -XX:+CMSClassUnloadingEnabled -XX:MaxPermSize=256m')
+    }
+    publishers {
+        archiveArtifacts('apps/willrogers/target/rpm/RPMS/noarch/*.rpm')
+    }
+}

apps/willrogers/app/controllers/ProjectPage.scala

@@ -43,18 +43,32 @@ object ProjectPage extends Controller {
         val trackOpt : Option[Track] = trackFactory.getTrack( trackDesc)
         trackOpt match {
           case Some(track) =>
-          val internalGoals = track.topLevelGoals.toList
-          val externalGoals = track.externalGoals.toList
+             val internalGoals = track.topLevelGoals.toList
+             val externalGoals = track.externalGoals.toList
 
-          val goalLogMap = LogWrapper.getGoalLogName(projName)
-          .filterNot(line => line == ".DS_Store")
-          
-          Ok(views.html.showproject(track.descriptor, internalGoals map (_.name), externalGoals map (_.name), goalLogMap))
+             val goalLogMap = LogWrapper.getGoalLogName(track.descriptor.trackName)
+                .filterNot(line => line == ".DS_Store")
+
+             Ok(views.html.showproject(track.descriptor, internalGoals map (_.name), externalGoals map (_.name), goalLogMap))
         case None =>
           Ok( views.html.brokenproject( projName))
         }
 
     }
+
+
+    def refreshTrack( trackName : String ) = Action {
+       val td = TrackDescriptor(trackName)
+       val track = trackFactory.refreshTrack(td)
+       val internalGoals = track.topLevelGoals.toList
+       val externalGoals = track.externalGoals.toList
+
+       val goalLogMap = LogWrapper.getGoalLogName(track.descriptor.trackName)
+          .filterNot(line => line == ".DS_Store")
+
+        Ok(views.html.showproject(track.descriptor, internalGoals map (_.name), externalGoals map (_.name), goalLogMap))
+    }
+
 
     def showProjectRuns (projName :String, goalName : String) = Action { // don't forget to add paging here later!
       //for logHistory ( on track page)

apps/willrogers/app/controllers/SatisfyGoalPage.scala

@@ -357,5 +357,4 @@ object SatisfyGoalPage extends Controller with Logging {
         val trackOpt : Option[Track] = ProjectPage.trackFactory.getTrack( trackDesc)
         trackOpt.get
     } 
-
-}
+}

apps/willrogers/app/controllers/ScheduleTrackPage.scala

@@ -42,7 +42,7 @@ object ScheduleTrackPage extends Controller {
     	 val tdList = trackFactory.getAllTracks
     	 //val tdList = Seq()
 
-     	Ok(views.html.scheduletrack(tdList, scList.toSeq))
+     	Ok(views.html.scheduletrack(tdList.toSeq, scList.toSeq))
    }
 
 
@@ -119,8 +119,8 @@ object ScheduleTrackPage extends Controller {
       println(" willrogers scheduler - I should be unscheduled!")
 
      val scList = scheduler.getScheduledTracks.map(_._1).toSeq
-     val tdList = trackFactory.getAllTracks.diff(scList)
+     val tdList = trackFactory.getAllTracks.toSeq.diff(scList)
      //Ok(views.html.scheduletrack(tdList, scList)) 
      Ok(s"track "+trackName+" unscheduled")
    }
-}
+}

apps/willrogers/app/views/showproject.scala.html

@@ -10,7 +10,7 @@
 
 
 
-@main( s"Track ${trackDesc.trackName} ") {
+@main(s"Track ${trackDesc.trackName} ") {
 
 <h1>Track @trackDesc.trackName  </h1>
 
@@ -39,6 +39,8 @@ <h3>External Dependencies</h3>
 
 
     </tr>
+    <tr><td>Refresh Track</td>
+    <td> <button id="refreshTrackButton" onClick="window.location.href='/refreshTrack/@helper.urlEncode(trackDesc.trackName)'">Refresh</button></td></tr>
  </table>    
 
 <div id ="[email protected]">
@@ -137,4 +139,4 @@ <h3> Goals</h3>
  </script>
 
 
-	}
+}

apps/willrogers/conf/routes

@@ -27,6 +27,7 @@ GET     /logwindow/:trackName/:goalName/:varString                   willrogers.
 GET     /rawlog/:trackName/:goalName/:varString                   willrogers.controllers.SatisfyGoalPage.rawLog(trackName: String, goalName: String, varString : String)
 GET     /restart/:trackName/:goalName/:varString                   willrogers.controllers.SatisfyGoalPage.restartJob(trackName: String, goalName: String, varString : String)
 GET     /abort/:trackName/:goalName/:varString                   willrogers.controllers.SatisfyGoalPage.abortJob(trackName: String, goalName: String, varString : String)
+GET		/refreshTrack/:trackName										willrogers.controllers.ProjectPage.refreshTrack(trackName: String)
 
 POST	/scheduletrack/:trackName/:forUser/:version										willrogers.controllers.ScheduleTrackPage.scheduleTrack(trackName: String, forUser: String, version: String)
 GET		/unscheduleonejob/:trackName/:forUser/:version						willrogers.controllers.ScheduleTrackPage.unscheduleOneTrack(trackName: String, forUser:String, version:String)