squelch log spam
This commit is contained in:
@@ -114,7 +114,7 @@ async def handle_order_cancel_all(event: EventData):
|
|||||||
|
|
||||||
async def handle_transfer(transfer: EventData):
|
async def handle_transfer(transfer: EventData):
|
||||||
# todo handle native transfers incl gas for token transfers
|
# todo handle native transfers incl gas for token transfers
|
||||||
log.debug(f'Transfer {transfer}')
|
# log.debug(f'Transfer {transfer}')
|
||||||
from_address = transfer['args']['from']
|
from_address = transfer['args']['from']
|
||||||
to_address = transfer['args']['to']
|
to_address = transfer['args']['to']
|
||||||
amount = int(transfer['args']['value'])
|
amount = int(transfer['args']['value'])
|
||||||
|
|||||||
@@ -57,6 +57,7 @@ class BlockProgressor(metaclass=ABCMeta):
|
|||||||
pass
|
pass
|
||||||
|
|
||||||
async def get_backfill_batches(self, from_height, to_height, w3=None):
|
async def get_backfill_batches(self, from_height, to_height, w3=None):
|
||||||
|
log.debug(f'querying backfill {from_height} through {to_height}')
|
||||||
if w3 is None:
|
if w3 is None:
|
||||||
w3 = current_w3.get()
|
w3 = current_w3.get()
|
||||||
batches = []
|
batches = []
|
||||||
@@ -67,7 +68,6 @@ class BlockProgressor(metaclass=ABCMeta):
|
|||||||
lf = dict(log_filter)
|
lf = dict(log_filter)
|
||||||
lf['fromBlock'] = from_height
|
lf['fromBlock'] = from_height
|
||||||
lf['toBlock'] = to_height
|
lf['toBlock'] = to_height
|
||||||
log.debug(f'querying backfill {from_height} through {to_height}')
|
|
||||||
get_logs = w3.eth.get_logs(lf)
|
get_logs = w3.eth.get_logs(lf)
|
||||||
if not config.parallel_logevent_queries:
|
if not config.parallel_logevent_queries:
|
||||||
get_logs = await get_logs
|
get_logs = await get_logs
|
||||||
|
|||||||
Reference in New Issue
Block a user