fix tests

onflow · Oct 1, 2024 · 7a141e5 · 7a141e5
1 parent e1a4a36
commit 7a141e5
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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{}