fix

disintar · Apr 20, 2024 · ee84276 · ee84276
1 parent 2b3ec01
commit ee84276
Showing 1 changed file with 16 additions and 12 deletions.
diff --git a/src/tonpy/blockscanner/blockscanner.py b/src/tonpy/blockscanner/blockscanner.py
@@ -579,18 +579,22 @@ def load_mcs(self, from_, to_):
         blocks_ids = list(range(from_, to_))
         mc_seqnos_chunks, p = self.detect_cs_p(blocks_ids)
 
-        with Pool(p) as pool:
-            results = pool.imap_unordered(process_mc_blocks(lcparams=self.lcparams, loglevel=self.loglevel,
-                                                            parse_txs_over_ls=self.parse_txs_over_ls),
-                                          enumerate(mc_seqnos_chunks))
-
-            if self.loglevel > 1:
-                results = tqdm(results, desc="Download MC blocks", total=len(mc_seqnos_chunks))
-
-            for result in results:
-                if result is None:
-                    raise ValueError(f"Invalid result in MC blocks")
-                mc_data.extend(result)
+        # with Pool(p) as pool:
+        #     results = pool.imap_unordered(process_mc_blocks(lcparams=self.lcparams, loglevel=self.loglevel,
+        #                                                     parse_txs_over_ls=self.parse_txs_over_ls),
+        #                                   enumerate(mc_seqnos_chunks))
+        #
+        #     if self.loglevel > 1:
+        #         results = tqdm(results, desc="Download MC blocks", total=len(mc_seqnos_chunks))
+        #
+        #     for result in results:
+        #         if result is None:
+        #             raise ValueError(f"Invalid result in MC blocks")
+        #         mc_data.extend(result)
+
+        for i in tqdm(enumerate(mc_seqnos_chunks), total=len(mc_seqnos_chunks)):
+            mc_data.extend(process_mc_blocks(i, lcparams=self.lcparams, loglevel=self.loglevel,
+                                             parse_txs_over_ls=self.parse_txs_over_ls))
 
         # todo: check hashes
         return mc_data