kopia lustrzana https://github.com/bugout-dev/moonstream
Added --jobs argument to "blocks synchronize"
rodzic
5ebb4491d0
commit
84a7a6acaf
|
@ -103,6 +103,7 @@ def ethcrawler_blocks_sync_handler(args: argparse.Namespace) -> None:
|
|||
crawl_blocks_executor(
|
||||
block_numbers_list=blocks_numbers_list,
|
||||
with_transactions=bool(strtobool(args.transactions)),
|
||||
num_processes=args.jobs,
|
||||
)
|
||||
|
||||
print(f"Synchronized blocks from {bottom_block_number} to {top_block_number}")
|
||||
|
@ -225,6 +226,16 @@ def main() -> None:
|
|||
default=ProcessingOrder.DESCENDING,
|
||||
help="Order in which to process blocks (choices: desc, asc; default: desc)",
|
||||
)
|
||||
parser_ethcrawler_blocks_sync.add_argument(
|
||||
"-j",
|
||||
"--jobs",
|
||||
type=int,
|
||||
default=MOONSTREAM_CRAWL_WORKERS,
|
||||
help=(
|
||||
f"Number of processes to use when synchronizing (default: {MOONSTREAM_CRAWL_WORKERS})."
|
||||
" If you set to 1, the main process handles synchronization without spawning subprocesses."
|
||||
)
|
||||
)
|
||||
parser_ethcrawler_blocks_sync.set_defaults(func=ethcrawler_blocks_sync_handler)
|
||||
|
||||
parser_ethcrawler_blocks_add = subcommands_ethcrawler_blocks.add_parser(
|
||||
|
|
Ładowanie…
Reference in New Issue