diff --git a/dtmgrpc/workflow/workflow.go b/dtmgrpc/workflow/workflow.go
index f00a30b..e9a66aa 100644
--- a/dtmgrpc/workflow/workflow.go
+++ b/dtmgrpc/workflow/workflow.go
@@ -137,7 +137,7 @@ func (wf *Workflow) OnCommit(fn WfPhase2Func) *Workflow {
 	branchID := wf.currentBranch
 	dtmimp.PanicIf(wf.currentCommitAdded, fmt.Errorf("one branch can only add one commit callback"))
 	wf.currentCommitAdded = true
-	wf.failedOps = append(wf.succeededOps, workflowPhase2Item{
+	wf.succeededOps = append(wf.succeededOps, workflowPhase2Item{
 		branchID: branchID,
 		op:       dtmimp.OpCommit,
 		fn:       fn,
diff --git a/test/main_test.go b/test/main_test.go
index 6c24f0c..688c839 100644
--- a/test/main_test.go
+++ b/test/main_test.go
@@ -69,9 +69,12 @@ func TestMain(m *testing.M) {
 	// WorkflowStarup 1
 	workflow.InitHTTP(dtmutil.DefaultHTTPServer, Busi+"/workflow/resume")
 	workflow.InitGrpc(dtmutil.DefaultGrpcServer, busi.BusiGrpc, gsvr)
-	go busi.RunHTTP(hsvr)
 	go busi.RunGrpc(gsvr)
-
+	go busi.RunHTTP(hsvr)
+	r := m.Run()
+	if r != 0 {
+		os.Exit(r)
+	}
 	close(dtmsvr.TransProcessedTestChan)
 	gid, more := <-dtmsvr.TransProcessedTestChan
 	logger.FatalfIf(more, "extra gid: %s in test chan", gid)