Replace WorkflowIdReusePolicy.TerminateExisting by WorkflowIdConflictPolicy

mjameswh · mjameswh · commit 32a059685689 · 2025-12-05T11:06:32.000-05:00
diff --git a/message_passing/safe_message_handlers/starter.py b/message_passing/safe_message_handlers/starter.py
@@ -62,7 +62,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
`@@ -62,7 +62,7 @@ async def main(should_test_continue_as_new: bool):`
`62`	`62`	`ClusterManagerInput(test_continue_as_new=should_test_continue_as_new),`
`63`	`63`	`id=f"ClusterManagerWorkflow-{uuid.uuid4()}",`
`64`	`64`	`task_queue="safe-message-handlers-task-queue",`
`65`		`- id_reuse_policy=common.WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,`
	`65`	`+ id_conflict_policy=common.WorkflowIDConflictPolicy.TERMINATE_EXISTING,`
`66`	`66`	`)`
`67`	`67`	`delay_seconds = 10 if should_test_continue_as_new else 1`
`68`	`68`	`await do_cluster_lifecycle(cluster_manager_handle, delay_seconds=delay_seconds)`