File tree Expand file tree Collapse file tree 1 file changed +5
-8
lines changed
turbopack/crates/turbo-tasks-backend/src/backend Expand file tree Collapse file tree 1 file changed +5
-8
lines changed Original file line number Diff line number Diff line change @@ -831,7 +831,6 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
831
831
return Ok ( Err ( self . listen_to_cell ( & mut task, task_id, reader, cell) . 0 ) ) ;
832
832
}
833
833
let is_cancelled = matches ! ( in_progress, Some ( InProgressState :: Canceled ) ) ;
834
- let is_scheduled = matches ! ( in_progress, Some ( InProgressState :: Scheduled { .. } ) ) ;
835
834
836
835
// Check cell index range (cell might not exist at all)
837
836
let max_id = get ! (
@@ -875,14 +874,12 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
875
874
// Schedule the task, if not already scheduled
876
875
if is_cancelled {
877
876
bail ! ( "{} was canceled" , ctx. get_task_description( task_id) ) ;
878
- } else if !is_scheduled
879
- && task. add ( CachedDataItem :: new_scheduled (
880
- TaskExecutionReason :: CellNotAvailable ,
881
- || self . get_task_desc_fn ( task_id) ,
882
- ) )
883
- {
884
- ctx. schedule_task ( task) ;
885
877
}
878
+ task. add_new ( CachedDataItem :: new_scheduled (
879
+ TaskExecutionReason :: CellNotAvailable ,
880
+ || self . get_task_desc_fn ( task_id) ,
881
+ ) ) ;
882
+ ctx. schedule_task ( task) ;
886
883
887
884
Ok ( Err ( listener) )
888
885
}
You can’t perform that action at this time.
0 commit comments