Skip to content

Commit

Permalink
Fix
Browse files Browse the repository at this point in the history
  • Loading branch information
tvorogme committed Apr 15, 2024
1 parent 7b839a5 commit 0186b14
Showing 1 changed file with 13 additions and 3 deletions.
16 changes: 13 additions & 3 deletions src/tonpy/blockscanner/blockscanner.py
Original file line number Diff line number Diff line change
Expand Up @@ -450,7 +450,15 @@ def process_mc_blocks(seqnos, lcparams, loglevel, parse_txs_over_ls):
raise e

sleep(0.1)
# del lc

if loglevel > 3:
logger.debug(f"[{thread_id}] Stop liteclient")

del lc

if loglevel > 2:
logger.debug(f"[{thread_id}] Done load MCs")

return answer
except Exception as e:
logger.error(f"{e}")
Expand Down Expand Up @@ -732,7 +740,6 @@ def load_historical(self):
logger.debug(f"Start load historical from seqno: {start_from}")

started_at = time()

mc_start_at = time()

end_at = None
Expand Down Expand Up @@ -879,10 +886,13 @@ def load_historical(self):

if not self.emulate_before_output:
if self.loglevel > 1:
logger.debug(f"Put transactions to output and continue to next chunk")
logger.debug(f"Put transactions to output and continue to next chunk, stop: {stop}")

self.out_queue.put(txs)
self.latest_processed = end_at

if self.loglevel > 3:
logger.debug(f"Data put, go")
continue

start_emulate_at = time()
Expand Down

0 comments on commit 0186b14

Please sign in to comment.