Update task_pool.py

learning-at-home · Sep 7, 2022 · c241505 · c241505
1 parent 1431240
commit c241505
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hivemind/moe/server/task_pool.py b/hivemind/moe/server/task_pool.py
@@ -170,7 +170,7 @@ def _pool_input_loop(self, pending_batches: Dict[Any, List[Task]], *args, **kwar
             for skip_i in range(prev_num_tasks):
                 finished_task_timestamp = (
                     self.undispatched_task_timestamps.get()
-                )  # earlier timestamp = lower (faster) priority
+                )  # earlier timestamp = smaller (better) priority, earlier processing
                 if skip_i == prev_num_tasks - 1:
                     self.priority = finished_task_timestamp