diff --git a/flow/cmd/handler.go b/flow/cmd/handler.go
index 2213636f65..15a5108251 100644
--- a/flow/cmd/handler.go
+++ b/flow/cmd/handler.go
@@ -283,7 +283,7 @@ func (h *FlowRequestHandler) dropFlow(
 		}
 	}
 
-	dropFlowWorkflowID := fmt.Sprintf("%s-dropflow-%s", flowJobName, uuid.New())
+	dropFlowWorkflowID := flowJobName + "-peerflow"
 	workflowOptions := client.StartWorkflowOptions{
 		ID:                    dropFlowWorkflowID,
 		TaskQueue:             h.peerflowTaskQueueID,
@@ -341,7 +341,7 @@ func (h *FlowRequestHandler) shutdownFlow(
 			return fmt.Errorf("unable to get cdc config from catalog: %w", err)
 		}
 	}
-	dropFlowWorkflowID := fmt.Sprintf("%s-dropflow-%s", flowJobName, uuid.New())
+	dropFlowWorkflowID := flowJobName + "-peerflow"
 	workflowOptions := client.StartWorkflowOptions{
 		ID:                    dropFlowWorkflowID,
 		TaskQueue:             h.peerflowTaskQueueID,