diff --git a/telemetry_api/lib/telemetry_api/periodically.ex b/telemetry_api/lib/telemetry_api/periodically.ex index 6aae11982..e31d01683 100644 --- a/telemetry_api/lib/telemetry_api/periodically.ex +++ b/telemetry_api/lib/telemetry_api/periodically.ex @@ -48,14 +48,14 @@ defmodule TelemetryApi.Periodically do EthereumMetrics.new_gas_price(gas_price) {:error, error} -> - IO.inspect("Error fetching gas price: #{error}") + Logger.error("Error fetching gas price: #{inspect(error)}") end {:noreply, %{}} end defp fetch_operators_info() do case Operators.fetch_all_operators() do :ok -> :ok - {:error, message} -> IO.inspect("Couldn't fetch operators: #{IO.inspect(message)}") + {:error, message} -> Logger.error("Couldn't fetch operators: #{inspect(message)}") end end @@ -67,7 +67,7 @@ defmodule TelemetryApi.Periodically do Operators.update_operator(op, %{status: string_status(status)}) error -> - Logger.error("Error when updating status: #{error}") + Logger.error("Error when updating status: #{inspect(error)}") end end) :ok diff --git a/telemetry_api/lib/telemetry_api/traces.ex b/telemetry_api/lib/telemetry_api/traces.ex index e611f386a..ee7f73f20 100644 --- a/telemetry_api/lib/telemetry_api/traces.ex +++ b/telemetry_api/lib/telemetry_api/traces.ex @@ -91,7 +91,7 @@ defmodule TelemetryApi.Traces do }) IO.inspect( - "Operator response included. merkle_root: #{IO.inspect(merkle_root)} operator_id: #{IO.inspect(operator_id)}" + "Operator response included. merkle_root: #{inspect(merkle_root)} operator_id: #{inspect(operator_id)}" ) :ok @@ -124,11 +124,6 @@ defmodule TelemetryApi.Traces do | subspans: Map.delete(trace.subspans, :batcher) }) - with {:ok, _trace} <- set_current_trace(merkle_root) do - Tracer.end_span() - TraceStore.delete_trace(merkle_root) - end - :ok end end @@ -208,7 +203,6 @@ defmodule TelemetryApi.Traces do :ok end end - @doc """ Registers the sending of a batcher task to Ethereum in the task trace. @@ -298,7 +292,7 @@ defmodule TelemetryApi.Traces do :ok end end - + @doc """ Registers a bump in the gas price when the aggregator tries to respond to a task in the task trace.