Merge branch 'multi_cluster' of github.com:twitter/gizzard into multi…

…_cluster
caniszczyk · Dec 5, 2010 · 1a8b619 · 1a8b619
2 parents bfb82f7 + e701d61
commit 1a8b619
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/scala/com/twitter/gizzard/scheduler/JobScheduler.scala b/src/main/scala/com/twitter/gizzard/scheduler/JobScheduler.scala
@@ -7,7 +7,7 @@ import com.twitter.util.TimeConversions._
 import net.lag.configgy.ConfigMap
 import net.lag.kestrel.PersistentQueue
 import net.lag.logging.Logger
-import shards.ShardRejectedOperationException
+import shards.{ShardBlackHoleException, ShardRejectedOperationException}
 
 object JobScheduler {
   /**
@@ -183,6 +183,8 @@ class JobScheduler[J <: Job](val name: String,
         job()
         Stats.incr("job-success-count")
       } catch {
+        case e: ShardBlackHoleException =>
+          Stats.incr("job-blackholed-count")
         case e: ShardRejectedOperationException =>
           Stats.incr("job-darkmoded-count")
           errorQueue.put(job)