File tree Expand file tree Collapse file tree
crates/tako/src/internal/server Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -32,7 +32,6 @@ pub struct Core {
3232 // TODO: benchmark and possibly replace with a set
3333 single_node_ready_to_assign : Vec < TaskId > ,
3434 multi_node_queue : MultiNodeQueue ,
35- has_new_tasks : bool ,
3635
3736 sleeping_sn_tasks : Vec < TaskId > , // Tasks that cannot be scheduled to any available worker
3837
@@ -185,12 +184,6 @@ impl Core {
185184 self . worker_listen_port
186185 }
187186
188- pub fn check_has_new_tasks_and_reset ( & mut self ) -> bool {
189- let result = self . has_new_tasks ;
190- self . has_new_tasks = false ;
191- result
192- }
193-
194187 pub fn new_worker ( & mut self , worker : Worker ) {
195188 /* Wake up sleeping tasks */
196189 let mut sleeping_sn_tasks = self . take_sleeping_tasks ( ) ;
@@ -287,7 +280,6 @@ impl Core {
287280 pub fn add_task ( & mut self , task : Task ) {
288281 let is_ready = task. is_ready ( ) ;
289282 let task_id = task. id ;
290- self . has_new_tasks = true ;
291283 assert ! ( self . tasks. insert( task) . is_none( ) ) ;
292284 if is_ready {
293285 self . add_ready_to_assign ( task_id) ;
You can’t perform that action at this time.
0 commit comments