Fix child_id in PostgresConnector error handlers

child_id was changed in 44533ce
electric-sql · May 3, 2024 · 29aec59 · 29aec59
1 parent 364b603
commit 29aec59
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/components/electric/lib/electric/replication/postgres_connector.ex b/components/electric/lib/electric/replication/postgres_connector.ex
@@ -4,6 +4,7 @@ defmodule Electric.Replication.PostgresConnector do
   require Logger
 
   alias Electric.Replication.Connectors
+  alias Electric.Replication.Postgres.LogicalReplicationProducer
   alias Electric.Replication.PostgresConnectorMng
   alias Electric.Replication.PostgresConnectorSup
 
@@ -87,7 +88,7 @@ defmodule Electric.Replication.PostgresConnector do
   end
 
   defp log_child_error(
-         :postgres_producer,
+         LogicalReplicationProducer,
          {:bad_return_value,
           {:error,
            {:error, :error, "55006", :object_in_use, "replication slot" <> _ = msg, _c_stacktrace}}},
@@ -104,7 +105,7 @@ defmodule Electric.Replication.PostgresConnector do
   end
 
   defp log_child_error(
-         :postgres_producer,
+         LogicalReplicationProducer,
          {:bad_return_value, {:error, :wal_level_not_logical}},
          _connector_config
        ) do
@@ -119,7 +120,7 @@ defmodule Electric.Replication.PostgresConnector do
   end
 
   defp log_child_error(
-         :postgres_producer,
+         LogicalReplicationProducer,
          {:bad_return_value, {:error, {:create_replication_slot_syntax_error, msg}}},
          _connector_config
        ) do