From 227456090f4d5650fb0652d300e092c48d4c1737 Mon Sep 17 00:00:00 2001 From: Priya Bibra Date: Fri, 15 Sep 2023 11:47:54 -0700 Subject: [PATCH] update regex Signed-off-by: Priya Bibra --- go/vt/vtgate/endtoend/vstream_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go/vt/vtgate/endtoend/vstream_test.go b/go/vt/vtgate/endtoend/vstream_test.go index 0b68be05b48..f0de4c9582b 100644 --- a/go/vt/vtgate/endtoend/vstream_test.go +++ b/go/vt/vtgate/endtoend/vstream_test.go @@ -484,7 +484,7 @@ func TestVStreamCopyResume(t *testing.T) { // Validate that the vgtid event the client receives from the vstream copy has a complete TableLastPK proto message. // Also, to ensure that the client can resume properly, make sure that // the Fields value is present in the sqltypes.Result field and not missing. - require.Regexp(t, `type:VGTID vgtid:{shard_gtids:{keyspace:"ks" shard:"-80" gtid:".+" table_p_ks:{table_name:"t1_copy_resume" lastpk:{fields:{name:"id1" type:INT64} rows:{lengths:1 values:"[0-9]"}}}} shard_gtids:{keyspace:"ks" shard:"80-" gtid:".+" table_p_ks:{table_name:"t1_copy_resume" lastpk:{fields:{name:"id1" type:INT64} rows:{lengths:1 values:"[0-9]"}}}}} keyspace:"ks" shard:"(80-|-80)"`, ev.String()) + require.Regexp(t, `type:VGTID vgtid:{(shard_gtids:{keyspace:"ks" shard:"(80-|-80)" gtid:".+" table_p_ks:{table_name:"t1_copy_resume" lastpk:{fields:{name:"id1" type:INT64} rows:{lengths:1 values:"[0-9]"}}}})+} keyspace:"ks" shard:"(80-|-80)"`, ev.String()) } } if expectedCatchupEvents == replCatchupEvents && expectedRowCopyEvents == rowCopyEvents {