post merge fix

serprex · serprex · commit f126b9c3d4ac · 2024-03-01T21:10:23.000Z
diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
@@ -530,14 +530,11 @@ type WorkflowRun struct {
 }
 
 func ExecutePeerflow(tc client.Client, wf interface{}, args ...interface{}) WorkflowRun {
-	return ExecuteWorkflow(tc, shared.PeerFlowTaskQueueID, wf, args...)
+	return ExecuteWorkflow(tc, shared.PeerFlowTaskQueue, wf, args...)
 }
 
 func ExecuteWorkflow(tc client.Client, taskQueueID shared.TaskQueueID, wf interface{}, args ...interface{}) WorkflowRun {
-	taskQueue, err := shared.GetPeerFlowTaskQueueName(taskQueueID)
-	if err != nil {
-		panic(err)
-	}
+	taskQueue := shared.GetPeerFlowTaskQueueName(taskQueueID)
 
 	wr, err := tc.ExecuteWorkflow(
 		context.Background(),

Original file line number	Diff line number	Diff line change
`@@ -530,14 +530,11 @@ type WorkflowRun struct {`
`530`	`530`	`}`
`531`	`531`
`532`	`532`	`func ExecutePeerflow(tc client.Client, wf interface{}, args ...interface{}) WorkflowRun {`
`533`		`- return ExecuteWorkflow(tc, shared.PeerFlowTaskQueueID, wf, args...)`
	`533`	`+ return ExecuteWorkflow(tc, shared.PeerFlowTaskQueue, wf, args...)`
`534`	`534`	`}`
`535`	`535`
`536`	`536`	`func ExecuteWorkflow(tc client.Client, taskQueueID shared.TaskQueueID, wf interface{}, args ...interface{}) WorkflowRun {`
`537`		`- taskQueue, err := shared.GetPeerFlowTaskQueueName(taskQueueID)`
`538`		`- if err != nil {`
`539`		`- panic(err)`
`540`		`- }`
	`537`	`+ taskQueue := shared.GetPeerFlowTaskQueueName(taskQueueID)`
`541`	`538`
`542`	`539`	`wr, err := tc.ExecuteWorkflow(`
`543`	`540`	`context.Background(),`