From 7a141e5b5cd2cb2b36741cfbb9ef7789e25a8b1f Mon Sep 17 00:00:00 2001 From: Illia Malachyn Date: Tue, 1 Oct 2024 17:36:28 +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 ad5105520..b10591973 100644 --- a/access/grpc/grpc_test.go +++ b/access/grpc/grpc_test.go @@ -2182,7 +2182,7 @@ func TestClient_SubscribeBlocks(t *testing.T) { On("SubscribeBlocksFromStartHeight", ctx, mock.Anything). Return(stream, nil) - blockCh, errCh, err := c.SubscribeBlocksFromStartHeight(ctx, startHeight, flow.BlockStatusUnknown) + blockCh, errCh, err := c.SubscribeBlocksFromStartHeight(ctx, startHeight, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{} @@ -2214,7 +2214,7 @@ func TestClient_SubscribeBlocks(t *testing.T) { Return(stream, nil) startBlockID := convert.MessageToIdentifier(stream.responses[0].Block.Id) - blockCh, errCh, err := c.SubscribeBlocksFromStartBlockID(ctx, startBlockID, flow.BlockStatusUnknown) + blockCh, errCh, err := c.SubscribeBlocksFromStartBlockID(ctx, startBlockID, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{} @@ -2245,7 +2245,7 @@ func TestClient_SubscribeBlocks(t *testing.T) { On("SubscribeBlocksFromLatest", ctx, mock.Anything). Return(stream, nil) - blockCh, errCh, err := c.SubscribeBlocksFromLatest(ctx, flow.BlockStatusUnknown) + blockCh, errCh, err := c.SubscribeBlocksFromLatest(ctx, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{} @@ -2275,7 +2275,7 @@ func TestClient_SubscribeBlocks(t *testing.T) { On("SubscribeBlocksFromLatest", ctx, mock.Anything). Return(stream, nil) - blockCh, errCh, err := c.SubscribeBlocksFromLatest(ctx, flow.BlockStatusUnknown) + blockCh, errCh, err := c.SubscribeBlocksFromLatest(ctx, flow.BlockStatusFinalized) require.NoError(t, err) wg := sync.WaitGroup{}