MulticallHistoricalTask

Documentation for eth_defi.event_reader.multicall_batcher.MulticallHistoricalTask Python class.

class MulticallHistoricalTask

Bases: object

Pickled task send between multicall reader loop and subprocesses.

Send a batch of calls to a specific block.

Attributes summary

chain_id

Track which chain this call belongs to

web3factory

Used to initialise web3 connection in the subprocess

block_number

Block number to sccan

calls

Multicalls to perform

require_multicall_result

Debug parameter to early abort if we get invalid replies from Multicall contract

timestamp

Fetch timestamp not given.

task_id

Running counter for task ids, for serialisation checks

Methods summary

__init__(chain_id, web3factory, ...[, ...])

chain_id: int

Track which chain this call belongs to

web3factory: eth_defi.event_reader.web3factory.Web3Factory

Used to initialise web3 connection in the subprocess

block_number: Union[Literal['latest', 'earliest', 'pending', 'safe', 'finalized'], eth_typing.evm.BlockNumber, eth_typing.evm.Hash32, eth_typing.encoding.HexStr, int]

Block number to sccan

calls: list[eth_defi.event_reader.multicall_batcher.EncodedCall]

Multicalls to perform

require_multicall_result: bool

Debug parameter to early abort if we get invalid replies from Multicall contract

timestamp: datetime.datetime

Fetch timestamp not given.

Otherwise prefetched

task_id: int

Running counter for task ids, for serialisation checks

__init__(chain_id, web3factory, block_number, calls, require_multicall_result=False, timestamp=None, task_id=<factory>)
Parameters
Return type

None