extract_events_concurrent

Documentation for eth_defi.event_reader.reader.extract_events_concurrent function.

extract_events_concurrent(start_block, end_block, filter, context=None, extract_timestamps=<function extract_timestamps_json_rpc>)

Concurrency happy event extractor.

You should use read_events_concurrent() unless you know the block range is something your node can handle.

Called by the thread pool - you probably do not want to call this directly.

Assumes the web3 connection is preset when the concurrent worker has been created, see get_worker_web3().

Parameters

• start_block (int) –

• end_block (int) –

• filter (eth_defi.event_reader.filter.Filter) –

• context (Optional[eth_defi.event_reader.logresult.LogContext]) –

• extract_timestamps (Optional[Callable]) –

Return type

List[eth_defi.event_reader.logresult.LogResult]