chore: fix flaky tests (#1930)

Author: edgurgel

test/realtime/extensions/cdc_rls/subscriptions_test.exs

@@ -177,8 +177,11 @@ defmodule Realtime.Extensions.PostgresCdcRls.SubscriptionsTest do
       assert {:ok, [%Postgrex.Result{}]} =
                Subscriptions.create(conn, "supabase_realtime_test", params_list, self(), self())
 
-      %Postgrex.Result{rows: [[[], "*"]]} =
-        Postgrex.query!(conn, "select filters, action_filter from realtime.subscription", [])
+      assert %Postgrex.Result{rows: rows} =
+               Postgrex.query!(conn, "select filters, action_filter from realtime.subscription", [])
+
+      assert rows != []
+      assert Enum.all?(rows, &match?([[], "*"], &1))
     end
 
     test "user can subscribe to only INSERT events", %{conn: conn} do
@@ -192,8 +195,11 @@ defmodule Realtime.Extensions.PostgresCdcRls.SubscriptionsTest do
       assert {:ok, [%Postgrex.Result{}]} =
                Subscriptions.create(conn, "supabase_realtime_test", params_list, self(), self())
 
-      %Postgrex.Result{rows: [[[], "INSERT"]]} =
-        Postgrex.query!(conn, "select filters, action_filter from realtime.subscription", [])
+      assert %Postgrex.Result{rows: rows} =
+               Postgrex.query!(conn, "select filters, action_filter from realtime.subscription", [])
+
+      assert rows != []
+      assert Enum.all?(rows, &match?([[], "INSERT"], &1))
     end
 
     test "user can subscribe to a specific table", %{conn: conn} do

test/realtime/tenants/connect_test.exs

@@ -507,7 +507,7 @@ defmodule Realtime.Tenants.ConnectTest do
       Process.exit(replication_connection_pid, :kill)
       assert_receive {:DOWN, _, :process, ^replication_connection_pid, _}
 
-      Process.sleep(100)
+      Process.sleep(1000)
       assert {:error, :not_connected} = Connect.replication_status(tenant.external_id)
 
       new_replication_connection_pid = assert_pid(fn -> ReplicationConnection.whereis(tenant.external_id) end)
@@ -516,7 +516,7 @@ defmodule Realtime.Tenants.ConnectTest do
       assert Process.alive?(new_replication_connection_pid)
       assert Process.alive?(pid)
 
-      assert {:ok, replication_conn_after} = assert_replication_status(tenant.external_id)
+      assert {:ok, replication_conn_after} = assert_replication_status(tenant.external_id, 60)
       assert replication_conn_before != replication_conn_after
     end