Skip to content

Commit 1a88ace

Browse files
committed
bugfix
1 parent 398e2b6 commit 1a88ace

File tree

1 file changed

+10
-9
lines changed
  • turbopack/crates/turbo-tasks-backend/src/backend

1 file changed

+10
-9
lines changed

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

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2416,6 +2416,16 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
24162416
new_current_session_self_clean,
24172417
}
24182418
.compute();
2419+
if result.dirty_count_update - result.current_session_clean_update < 0 {
2420+
// The task is clean now
2421+
if let Some(activeness_state) = get_mut!(task, Activeness) {
2422+
activeness_state.all_clean_event.notify(usize::MAX);
2423+
activeness_state.unset_active_until_clean();
2424+
if activeness_state.is_empty() {
2425+
task.remove(&CachedDataItemKey::Activeness {});
2426+
}
2427+
}
2428+
}
24192429
result
24202430
.aggregated_update(task_id)
24212431
.and_then(|aggregated_update| {
@@ -2425,15 +2435,6 @@ impl<B: BackingStorage> TurboTasksBackendInner<B> {
24252435
None
24262436
};
24272437

2428-
if let Some(activeness_state) = get_mut!(task, Activeness) {
2429-
// The task is clean now
2430-
activeness_state.all_clean_event.notify(usize::MAX);
2431-
activeness_state.unset_active_until_clean();
2432-
if activeness_state.is_empty() {
2433-
task.remove(&CachedDataItemKey::Activeness {});
2434-
}
2435-
}
2436-
24372438
#[cfg(feature = "verify_determinism")]
24382439
let reschedule = (dirty_changed || no_output_set) && !task_id.is_transient();
24392440
#[cfg(not(feature = "verify_determinism"))]

0 commit comments

Comments
 (0)