Handle tasks run by another crank turner then replaced by new tasks (simulated) (#82)

ChewingGlass · web-flow · commit 1b281ae0189e · 2025-12-23T10:49:36.000-08:00
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/tuktuk-crank-turner/Cargo.toml b/tuktuk-crank-turner/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "tuktuk-crank-turner"
-version = "0.2.26"
+version = "0.2.27"
 authors.workspace = true
 edition.workspace = true
 license.workspace = true
diff --git a/tuktuk-crank-turner/src/task_processor.rs b/tuktuk-crank-turner/src/task_processor.rs
@@ -289,6 +289,19 @@ impl TimedTask {
                 {
                     info!(?self.task_key, "task was already replaced, skipping");
                 }
+                TransactionQueueError::SimulatedTransactionError(
+                    TransactionError::InstructionError(_, InstructionError::Custom(code)),
+                ) if code == 6005
+                    && ctx
+                        .rpc_client
+                        .anchor_account::<TaskV0>(&self.task_key)
+                        .await
+                        .ok()
+                        .flatten()
+                        .is_some_and(|acc| acc.queued_at != self.task.queued_at) =>
+                {
+                    info!(?self.task_key, "task was already replaced, skipping");
+                }
                 TransactionQueueError::RawTransactionError(_)
                 | TransactionQueueError::SimulatedTransactionError(_)
                 | TransactionQueueError::TransactionError(_)
