From 3bc5768e706054be474fd66d37e8d96e78864d49 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Thu, 11 Feb 2021 15:17:25 +0300 Subject: [PATCH] Remove incorrect test --- tests/hp_test.go | 66 ------------------------------------------------ 1 file changed, 66 deletions(-) diff --git a/tests/hp_test.go b/tests/hp_test.go index 35845abb..150b6226 100644 --- a/tests/hp_test.go +++ b/tests/hp_test.go @@ -309,39 +309,6 @@ func Test_ActivityHeartbeat(t *testing.T) { wg.Wait() } -func Test_FailedActivityHeartbeat(t *testing.T) { - stopCh := make(chan struct{}, 1) - wg := &sync.WaitGroup{} - wg.Add(1) - s := NewTestServer(t, stopCh, wg, false) - - w, err := s.Client().ExecuteWorkflow( - context.Background(), - client.StartWorkflowOptions{ - TaskQueue: "default", - }, - "FailedHeartbeatWorkflow", - 1, - ) - assert.NoError(t, err) - - time.Sleep(time.Second) - - we, err := s.Client().DescribeWorkflowExecution(context.Background(), w.GetID(), w.GetRunID()) - assert.NoError(t, err) - assert.Len(t, we.PendingActivities, 1) - - act := we.PendingActivities[0] - - assert.Equal(t, `{"value":1}`, string(act.HeartbeatDetails.Payloads[0].Data)) - - var result string - assert.NoError(t, w.Get(context.Background(), &result)) - assert.Equal(t, "OK!", result) - stopCh <- struct{}{} - wg.Wait() -} - func Test_BinaryPayload(t *testing.T) { stopCh := make(chan struct{}, 1) wg := &sync.WaitGroup{} @@ -758,39 +725,6 @@ func Test_ActivityHeartbeatProto(t *testing.T) { wg.Wait() } -func Test_FailedActivityHeartbeatProto(t *testing.T) { - stopCh := make(chan struct{}, 1) - wg := &sync.WaitGroup{} - wg.Add(1) - s := NewTestServer(t, stopCh, wg, true) - - w, err := s.Client().ExecuteWorkflow( - context.Background(), - client.StartWorkflowOptions{ - TaskQueue: "default", - }, - "FailedHeartbeatWorkflow", - 1, - ) - assert.NoError(t, err) - - time.Sleep(time.Second) - - we, err := s.Client().DescribeWorkflowExecution(context.Background(), w.GetID(), w.GetRunID()) - assert.NoError(t, err) - assert.Len(t, we.PendingActivities, 1) - - act := we.PendingActivities[0] - - assert.Equal(t, `{"value":1}`, string(act.HeartbeatDetails.Payloads[0].Data)) - - var result string - assert.NoError(t, w.Get(context.Background(), &result)) - assert.Equal(t, "OK!", result) - stopCh <- struct{}{} - wg.Wait() -} - func Test_BinaryPayloadProto(t *testing.T) { stopCh := make(chan struct{}, 1) wg := &sync.WaitGroup{}