Crash counter increased only when worker fails

It4innovations · Sep 20, 2024 · 76496be · 76496be
1 parent 91278b5
commit 76496be
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/crates/tako/src/internal/server/reactor.rs b/crates/tako/src/internal/server/reactor.rs
@@ -55,7 +55,7 @@ pub(crate) fn on_remove_worker(
                     task.set_fresh_flag(true);
                     ready_to_assign.push(task_id);
                     if task.is_sn_running() {
-                        if task.increment_crash_counter() {
+                        if reason.is_failure() && task.increment_crash_counter() {
                             crashed_tasks.push(task_id);
                         } else {
                             running_tasks.push(task_id);