diff --git a/dtmsvr/dtmsvr_test.go b/dtmsvr/dtmsvr_test.go index 5196d3c..a1f5894 100644 --- a/dtmsvr/dtmsvr_test.go +++ b/dtmsvr/dtmsvr_test.go @@ -221,9 +221,9 @@ func msgPending(t *testing.T) { func sagaNormal(t *testing.T) { saga := genSaga("gid-noramlSaga", false, false) saga.Submit() - assert.Equal(t, "submitted", getTransStatus(saga.Gid)) WaitTransProcessed(saga.Gid) assert.Equal(t, []string{"prepared", "succeed", "prepared", "succeed"}, getBranchesStatus(saga.Gid)) + assert.Equal(t, "succeed", getTransStatus(saga.Gid)) transQuery(t, saga.Gid) }