|
|
@ -205,7 +205,8 @@ defmodule Indexer.Fetcher.InternalTransaction do |
|
|
|
{hash, block_number} |
|
|
|
{hash, block_number} |
|
|
|
end) |
|
|
|
end) |
|
|
|
|
|
|
|
|
|
|
|
case Chain.import(%{ |
|
|
|
imports = |
|
|
|
|
|
|
|
Chain.import(%{ |
|
|
|
addresses: %{params: addresses_params}, |
|
|
|
addresses: %{params: addresses_params}, |
|
|
|
internal_transactions: %{params: internal_transactions_params_without_failed_creations}, |
|
|
|
internal_transactions: %{params: internal_transactions_params_without_failed_creations}, |
|
|
|
internal_transactions_indexed_at_blocks: %{ |
|
|
|
internal_transactions_indexed_at_blocks: %{ |
|
|
@ -213,7 +214,9 @@ defmodule Indexer.Fetcher.InternalTransaction do |
|
|
|
with: :number_only_changeset |
|
|
|
with: :number_only_changeset |
|
|
|
}, |
|
|
|
}, |
|
|
|
timeout: :infinity |
|
|
|
timeout: :infinity |
|
|
|
}) do |
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
case imports do |
|
|
|
{:ok, imported} -> |
|
|
|
{:ok, imported} -> |
|
|
|
async_import_coin_balances(imported, %{ |
|
|
|
async_import_coin_balances(imported, %{ |
|
|
|
address_hash_to_fetched_balance_block_number: address_hash_to_block_number |
|
|
|
address_hash_to_fetched_balance_block_number: address_hash_to_block_number |
|
|
|