chainbench
Advanced tools
@@ -472,2 +472,3 @@ import logging | ||
| "pending", | ||
| "finalized", | ||
| ]: | ||
@@ -474,0 +475,0 @@ raise ValueError("Invalid block number") |
+35
-35
@@ -200,41 +200,41 @@ import logging | ||
| user_test_data.init_data(environment.parsed_options) | ||
| test_data[test_data_class_name] = user_test_data.data.to_json() | ||
| send_msg_to_workers(environment.runner, "test_data", test_data) | ||
| print("Fetching blocks...") | ||
| if environment.parsed_options.use_latest_blocks: | ||
| print(f"Using latest {user_test_data.data.size.blocks_len} blocks as test data") | ||
| logger.info(f"Using latest {user_test_data.data.size.blocks_len} blocks as test data") | ||
| for block_number in range( | ||
| user_test_data.data.block_range.start, user_test_data.data.block_range.end + 1 | ||
| ): | ||
| block = None | ||
| try: | ||
| block = user_test_data.fetch_block(block_number) | ||
| except (BlockNotFoundError, InvalidBlockError): | ||
| pass | ||
| while block is None: | ||
| test_data[test_data_class_name] = user_test_data.data.to_json() | ||
| send_msg_to_workers(environment.runner, "test_data", test_data) | ||
| print("Fetching blocks...") | ||
| if environment.parsed_options.use_latest_blocks: | ||
| print(f"Using latest {user_test_data.data.size.blocks_len} blocks as test data") | ||
| logger.info(f"Using latest {user_test_data.data.size.blocks_len} blocks as test data") | ||
| for block_number in range( | ||
| user_test_data.data.block_range.start, user_test_data.data.block_range.end + 1 | ||
| ): | ||
| block = None | ||
| try: | ||
| block = user_test_data.fetch_latest_block() | ||
| block = user_test_data.fetch_block(block_number) | ||
| except (BlockNotFoundError, InvalidBlockError): | ||
| pass | ||
| user_test_data.data.push_block(block) | ||
| block_data = {test_data_class_name: block.to_json()} | ||
| send_msg_to_workers(environment.runner, "block_data", block_data) | ||
| print(user_test_data.data.stats(), end="\r") | ||
| while block is None: | ||
| try: | ||
| block = user_test_data.fetch_latest_block() | ||
| except (BlockNotFoundError, InvalidBlockError): | ||
| pass | ||
| user_test_data.data.push_block(block) | ||
| block_data = {test_data_class_name: block.to_json()} | ||
| send_msg_to_workers(environment.runner, "block_data", block_data) | ||
| print(user_test_data.data.stats(), end="\r") | ||
| else: | ||
| print(user_test_data.data.stats(), end="\r") | ||
| print("\n") # new line after progress display upon exiting loop | ||
| else: | ||
| print(user_test_data.data.stats(), end="\r") | ||
| print("\n") # new line after progress display upon exiting loop | ||
| else: | ||
| while user_test_data.data.size.blocks_len > len(user_test_data.data.blocks): | ||
| try: | ||
| block = user_test_data.fetch_random_block(user_test_data.data.block_numbers) | ||
| except (BlockNotFoundError, InvalidBlockError): | ||
| continue | ||
| user_test_data.data.push_block(block) | ||
| block_data = {test_data_class_name: block.to_json()} | ||
| send_msg_to_workers(environment.runner, "block_data", block_data) | ||
| print(user_test_data.data.stats(), end="\r") | ||
| else: | ||
| print(user_test_data.data.stats(), end="\r") | ||
| print("\n") # new line after progress display upon exiting loop | ||
| while user_test_data.data.size.blocks_len > len(user_test_data.data.blocks): | ||
| try: | ||
| block = user_test_data.fetch_random_block(user_test_data.data.block_numbers) | ||
| except (BlockNotFoundError, InvalidBlockError): | ||
| continue | ||
| user_test_data.data.push_block(block) | ||
| block_data = {test_data_class_name: block.to_json()} | ||
| send_msg_to_workers(environment.runner, "block_data", block_data) | ||
| print(user_test_data.data.stats(), end="\r") | ||
| else: | ||
| print(user_test_data.data.stats(), end="\r") | ||
| print("\n") # new line after progress display upon exiting loop | ||
| logger.info("Test data is ready") | ||
@@ -241,0 +241,0 @@ send_msg_to_workers(environment.runner, "release_lock", {}) |
+1
-1
| Metadata-Version: 2.1 | ||
| Name: chainbench | ||
| Version: 0.8.4 | ||
| Version: 0.8.5 | ||
| Summary: | ||
@@ -5,0 +5,0 @@ Author: Egor Molodik |
+1
-1
| [tool.poetry] | ||
| name = "chainbench" | ||
| version = "0.8.4" | ||
| version = "0.8.5" | ||
| description = "" | ||
@@ -5,0 +5,0 @@ authors = [ |
Alert delta unavailable
Currently unable to show alert delta for PyPI packages.
324911
0.06%9017
0.01%