diff --git a/lib/towerops/monitoring/etcd_coordinator.ex b/lib/towerops/monitoring/etcd_coordinator.ex index 73ee7b56..57927bbd 100644 --- a/lib/towerops/monitoring/etcd_coordinator.ex +++ b/lib/towerops/monitoring/etcd_coordinator.ex @@ -130,7 +130,15 @@ defmodule Towerops.Monitoring.EtcdCoordinator do ~c"etcd-2.etcd.towerops.svc.cluster.local:2379" ] - :eetcd.open(:towerops_etcd, endpoints) + case :eetcd.open(:towerops_etcd, endpoints) do + {:ok, _pid} -> + # Return the connection name (atom), not the PID + # eetcd functions expect the connection name + {:ok, :towerops_etcd} + + {:error, _reason} = error -> + error + end end defp handle_watch_event(%{type: :delete, kv: %{key: key}}, conn) do