Add unit test

Signed-off-by: Matt Lord <mattalord@gmail.com>
vitessio · Feb 18, 2025 · 71439f8 · 71439f8
1 parent b5af7a5
commit 71439f8
Show file tree

Hide file tree

Showing 2 changed files with 1,043 additions and 1 deletion.
diff --git a/go/vt/vtctl/workflow/materializer_env_test.go b/go/vt/vtctl/workflow/materializer_env_test.go
@@ -497,7 +497,7 @@ func (tmc *testMaterializerTMClient) ReadVReplicationWorkflows(ctx context.Conte
 		streams := make([]*tabletmanagerdatapb.ReadVReplicationWorkflowResponse_Stream, len(tmc.sourceShards))
 		for i, shard := range tmc.sourceShards {
 			streams[i] = &tabletmanagerdatapb.ReadVReplicationWorkflowResponse_Stream{
-				Id:    1,
+				Id:    int32(i + 1),
 				State: binlogdatapb.VReplicationWorkflowState_Running,
 				Bls: &binlogdatapb.BinlogSource{
 					Keyspace: tmc.keyspace,