We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1c0508d commit 2a32765Copy full SHA for 2a32765
1 file changed
flow/connectors/mysql/replication_mechanism_test.go
@@ -66,7 +66,7 @@ func TestReplicationMechanismInUseFromOffsetText(t *testing.T) {
66
t.Run("empty", func(t *testing.T) {
67
mechanism, err := replicationMechanismInUseFromOffsetText("mysql", "")
68
require.NoError(t, err)
69
- require.Empty(t, mechanism)
+ require.Equal(t, protos.MySqlReplicationMechanism_MYSQL_GTID.String(), mechanism)
70
})
71
72
t.Run("invalid", func(t *testing.T) {
0 commit comments