From 6c72a9a19cea7bcdf0229671c50a5790d10c7516 Mon Sep 17 00:00:00 2001 From: Illia Malachyn Date: Tue, 1 Oct 2024 17:35:50 +0300 Subject: [PATCH] fix tests --- access/grpc/grpc_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/access/grpc/grpc_test.go b/access/grpc/grpc_test.go index e4e3e450a..53332d5fe 100644 --- a/access/grpc/grpc_test.go +++ b/access/grpc/grpc_test.go @@ -2182,7 +2182,7 @@ func TestClient_SubscribeBlockHeaders(t *testing.T) { On("SubscribeBlockHeadersFromStartHeight", ctx, mock.Anything). Return(stream, nil) - blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromStartHeight(ctx, startHeight, flow.BlockStatusUnknown) + blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromStartHeight(ctx, startHeight, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{} @@ -2214,7 +2214,7 @@ func TestClient_SubscribeBlockHeaders(t *testing.T) { Return(stream, nil) startBlockID := convert.MessageToIdentifier(stream.responses[0].GetHeader().Id) - blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromStartBlockID(ctx, startBlockID, flow.BlockStatusUnknown) + blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromStartBlockID(ctx, startBlockID, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{} @@ -2245,7 +2245,7 @@ func TestClient_SubscribeBlockHeaders(t *testing.T) { On("SubscribeBlockHeadersFromLatest", ctx, mock.Anything). Return(stream, nil) - blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromLatest(ctx, flow.BlockStatusUnknown) + blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromLatest(ctx, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{} @@ -2274,7 +2274,7 @@ func TestClient_SubscribeBlockHeaders(t *testing.T) { On("SubscribeBlockHeadersFromLatest", ctx, mock.Anything). Return(stream, nil) - blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromLatest(ctx, flow.BlockStatusUnknown) + blockHeadersCh, errCh, err := c.SubscribeBlockHeadersFromLatest(ctx, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{}