Skip to content

Commit

Permalink
Improve
Browse files Browse the repository at this point in the history
  • Loading branch information
tvorogme committed Apr 15, 2024
1 parent dda881f commit f7b6ae6
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions src/tonpy/blockscanner/blockscanner.py
Original file line number Diff line number Diff line change
Expand Up @@ -207,6 +207,8 @@ def process_block(block, lc, emulate_before_output, tx_subscriptions):
@curry
def load_process_blocks(blocks_chunk, lcparams, loglevel, emulate_before_output, tx_subscriptions):
lcparams = json.loads(lcparams)
lcparams['logprefix'] = 'blockprocessor'

with LiteClient(**lcparams) as lc:
blocks_txs = []

Expand Down Expand Up @@ -354,7 +356,7 @@ def load_process_shard(shards_chunk,
answer = []

lcparams = json.loads(lcparams)
lcparams['logprefix'] = f'{thread_id}'
lcparams['logprefix'] = f'shards t{thread_id}'
with LiteClient(**lcparams) as lc:
if loglevel > 1:
shards_chunk = tqdm(shards_chunk, desc=f"[{thread_id}] Load shards")
Expand Down Expand Up @@ -395,7 +397,7 @@ def process_mc_blocks(seqnos, lcparams, loglevel, parse_txs_over_ls):

try:
lcparams = json.loads(lcparams)
lcparams['logprefix'] = f'{thread_id}'
lcparams['logprefix'] = f'mcblocks t{thread_id}'

if loglevel > 3:
logger.debug(f"[{thread_id}] Start LiteClient")
Expand Down

0 comments on commit f7b6ae6

Please sign in to comment.