Skip to content

Commit db63b09

Browse files
committed
remove unneeded case
1 parent 642ae3e commit db63b09

File tree

1 file changed

+5
-8
lines changed
  • turbopack/crates/turbo-tasks-backend/src/backend

1 file changed

+5
-8
lines changed

turbopack/crates/turbo-tasks-backend/src/backend/mod.rs

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -831,7 +831,6 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
831831
return Ok(Err(self.listen_to_cell(&mut task, task_id, reader, cell).0));
832832
}
833833
let is_cancelled = matches!(in_progress, Some(InProgressState::Canceled));
834-
let is_scheduled = matches!(in_progress, Some(InProgressState::Scheduled { .. }));
835834

836835
// Check cell index range (cell might not exist at all)
837836
let max_id = get!(
@@ -875,14 +874,12 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
875874
// Schedule the task, if not already scheduled
876875
if is_cancelled {
877876
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);
885877
}
878+
task.add_new(CachedDataItem::new_scheduled(
879+
TaskExecutionReason::CellNotAvailable,
880+
|| self.get_task_desc_fn(task_id),
881+
));
882+
ctx.schedule_task(task);
886883

887884
Ok(Err(listener))
888885
}

0 commit comments

Comments
 (0)