Fix chunksize for little ammount of txs

setup.py

@@ -31,7 +31,7 @@ def finalize_options(self):
 
 setup(
     name="tonpy" if not IS_DEV else "tonpy-dev",
-    version="0.0.0.1.2b0" if not IS_DEV else "0.0.0.3.4a1",
+    version="0.0.0.1.2b0" if not IS_DEV else "0.0.0.3.4b1",
     author="Disintar LLP",
     author_email="[email protected]",
     description="Types / API for TON blockchain",

src/tonpy/blockscanner/blockscanner.py

@@ -550,14 +550,14 @@ def load_historical(self):
 
             if self.process_raw:
                 start_emulate_at = time()
-                tmp = chunks(txs, self.tx_chunk_size)
+                tmp = list(chunks(txs, self.tx_chunk_size))
 
                 if self.loglevel > 1:
-                    tmp = tqdm(tmp, desc="Process raw")
+                    tmp = tqdm(tmp, desc="Process raw", total=len(tmp))
 
                 for c in tmp:
                     with Pool(self.nproc) as pool:
-                        results = pool.imap_unordered(self.f, c, chunksize=math.ceil(len(c) / self.nproc))
+                        results = pool.imap_unordered(self.f, c, chunksize=max(200, math.ceil(len(c) / self.nproc)))
 
                         for result_chunk in results:
                             self.out_queue.put(result_chunk)

src/tonpy/blockscanner/subscriptions.py

@@ -5,7 +5,7 @@
 
 class CustomSubscription:
     def __init__(self):
-        pass
+        self.local_items = []
 
     def check(self, tx: CellSlice) -> bool:
         raise NotImplementedError
@@ -41,7 +41,6 @@ def check(self, tx: CellSlice) -> bool:
                         in_msg_text = in_msg_body.load_string(strict=False)
                         return self.text in in_msg_text
                     except Exception as e:
-                        print(e)
                         return False
 
         else: