Replace WorkflowIdReusePolicy.TerminateExisting by WorkflowIdConflictPolicy (temporalio#266)

mjameswh · web-flow · commit ce5d8dda9013 · 2026-04-02T17:16:33.000-04:00
diff --git 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)

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ async def main(should_test_continue_as_new: bool):`
`65`	`65`	`ClusterManagerInput(test_continue_as_new=should_test_continue_as_new),`
`66`	`66`	`id=f"ClusterManagerWorkflow-{uuid.uuid4()}",`
`67`	`67`	`task_queue="safe-message-handlers-task-queue",`
`68`		`- id_reuse_policy=common.WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,`
	`68`	`+ id_conflict_policy=common.WorkflowIDConflictPolicy.TERMINATE_EXISTING,`
`69`	`69`	`)`
`70`	`70`	`delay_seconds = 10 if should_test_continue_as_new else 1`
`71`	`71`	`await do_cluster_lifecycle(cluster_manager_handle, delay_seconds=delay_seconds)`