diff --git a/lib/xandra/connection.ex b/lib/xandra/connection.ex index 6ebb6f05..a7dc66d2 100644 --- a/lib/xandra/connection.ex +++ b/lib/xandra/connection.ex @@ -182,6 +182,7 @@ defmodule Xandra.Connection do # This is in an anonymous function so that we can use it in a Telemetry span. fun = fn -> with :ok <- Transport.send(transport, payload), + Logger.debug("Sent query on stream ID #{stream_id}, will wait for an answer"), {:ok, %Frame{} = frame} <- receive_response_frame(conn_pid, req_alias, checked_out_state, timeout) do case protocol_module.decode_response(frame, query, options) do