diff --git a/crates/relayer/src/worker/map.rs b/crates/relayer/src/worker/map.rs
index 65d80d1af1..c5305f52cb 100644
--- a/crates/relayer/src/worker/map.rs
+++ b/crates/relayer/src/worker/map.rs
@@ -125,7 +125,17 @@ impl WorkerMap {
         config: &Config,
     ) -> &WorkerHandle {
         if self.workers.contains_key(&object) {
-            &self.workers[&object]
+            if self.workers[&object].shutdown_stopped_tasks() {
+                self.remove_stopped(
+                    self.workers[&object].id(),
+                    self.workers[&object].object().clone(),
+                );
+
+                let worker = self.spawn_worker(src, dst, &object, config);
+                self.workers.entry(object).or_insert(worker)
+            } else {
+                &self.workers[&object]
+            }
         } else {
             let worker = self.spawn_worker(src, dst, &object, config);
             self.workers.entry(object).or_insert(worker)