Browse files

use medium priority for addUnsafe.

  • Loading branch information...
1 parent 49e5466 commit 53483f3ecdb96cd966bd9d8c3eadef31dd24a9be eaceaser committed Jan 9, 2011
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/main/scala/com/twitter/flockdb/EdgesService.scala
View
2 src/main/scala/com/twitter/flockdb/EdgesService.scala
@@ -103,7 +103,7 @@ class EdgesService(val nameServer: NameServer[shards.Shard],
def unsafeAdd(operations: Seq[UnsafeAddQuery]) {
rethrowExceptionsAsThrift {
- schedule.put(Priority.High.id, new JsonNestedJob(operations.map {
+ schedule.put(Priority.Medium.id, new JsonNestedJob(operations.map {
op => new UnsafeAddJob(op.sourceId, op.graphId, op.destinationId, op.createdAt.inMillis, Time.now, null, null)
} ))
}

0 comments on commit 53483f3

Please sign in to comment.