go: sqle/binlogreplication: Add some waits for more reliable observat…

…ions of IO_error results.
dolthub · Feb 4, 2025 · 6d95550 · 6d95550
1 parent b4b6d71
commit 6d95550
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/go/libraries/doltcore/sqle/binlogreplication/binlog_primary_test.go b/go/libraries/doltcore/sqle/binlogreplication/binlog_primary_test.go
@@ -53,6 +53,7 @@ func TestBinlogPrimary_BinlogNotEnabled(t *testing.T) {
 	h.requirePrimaryResults("SHOW BINARY LOGS", [][]any{})
 
 	h.startReplicationAndCreateTestDb(h.doltPort)
+	time.Sleep(1 * time.Second)
 	status := h.queryReplicaStatus()
 	require.Equal(t, "13120", status["Last_IO_Errno"])
 	require.Contains(t, status["Last_IO_Error"],
@@ -71,7 +72,7 @@ func TestBinlogPrimary_GtidModeNotEnabled(t *testing.T) {
 	h.requirePrimaryResults("SHOW BINARY LOGS", [][]any{{"binlog-main.000001", "151", "No"}})
 
 	h.startReplication(h.doltPort)
-	time.Sleep(500 * time.Millisecond)
+	time.Sleep(1 * time.Second)
 	status := h.queryReplicaStatus()
 	require.Equal(t, "13117", status["Last_IO_Errno"])
 	require.Contains(t, status["Last_IO_Error"],
@@ -90,7 +91,7 @@ func TestBinlogPrimary_EnforceGtidConsistencyNotEnabled(t *testing.T) {
 	h.requirePrimaryResults("SHOW BINARY LOGS", [][]any{{"binlog-main.000001", "151", "No"}})
 
 	h.startReplication(h.doltPort)
-	time.Sleep(500 * time.Millisecond)
+	time.Sleep(1 * time.Second)
 	status := h.queryReplicaStatus()
 	require.Equal(t, "13114", status["Last_IO_Errno"])
 	require.Contains(t, status["Last_IO_Error"],
@@ -257,6 +258,7 @@ func TestBinlogPrimary_AutoPurging(t *testing.T) {
 
 	// Verify the replica reports an error about the GTIDs not being available
 	h.startReplicationAndCreateTestDb(h.doltPort)
+	time.Sleep(1 * time.Second)
 	status := h.queryReplicaStatus()
 	require.Equal(t, "13114", status["Last_IO_Errno"])
 	require.Contains(t, status["Last_IO_Error"],
@@ -394,6 +396,7 @@ func TestBinlogPrimary_Heartbeats(t *testing.T) {
 		[][]any{{fmt.Sprintf("%d", maxInsertValue)}})
 
 	// Make sure no errors have occurred
+	time.Sleep(1 * time.Second)
 	status := h.queryReplicaStatus()
 	require.Equal(t, "", status["Last_SQL_Error"])
 	require.Equal(t, "", status["Last_IO_Error"])