diff --git a/message_passing/safe_message_handlers/starter.py b/message_passing/safe_message_handlers/starter.py
index 9bc5c6611..c8f1b5d39 100644
--- a/message_passing/safe_message_handlers/starter.py
+++ b/message_passing/safe_message_handlers/starter.py
@@ -65,7 +65,7 @@ async def main(should_test_continue_as_new: bool):
         ClusterManagerInput(test_continue_as_new=should_test_continue_as_new),
         id=f"ClusterManagerWorkflow-{uuid.uuid4()}",
         task_queue="safe-message-handlers-task-queue",
-        id_reuse_policy=common.WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
+        id_conflict_policy=common.WorkflowIDConflictPolicy.TERMINATE_EXISTING,
     )
     delay_seconds = 10 if should_test_continue_as_new else 1
     await do_cluster_lifecycle(cluster_manager_handle, delay_seconds=delay_seconds)