|
@ -3,6 +3,7 @@ import json |
|
|
import os |
|
|
import os |
|
|
import re |
|
|
import re |
|
|
import sys |
|
|
import sys |
|
|
|
|
|
import time |
|
|
from argparse import ArgumentParser |
|
|
from argparse import ArgumentParser |
|
|
from datetime import datetime |
|
|
from datetime import datetime |
|
|
from fnmatch import fnmatch |
|
|
from fnmatch import fnmatch |
|
@ -455,15 +456,21 @@ async def handle_pads(args): |
|
|
padids = padids[args.skip : len(padids)] |
|
|
padids = padids[args.skip : len(padids)] |
|
|
|
|
|
|
|
|
print("=" * 79) |
|
|
print("=" * 79) |
|
|
print("Etherpump warming up the engines ...") |
|
|
print("Etherpump is warming up the engines ...") |
|
|
print("=" * 79) |
|
|
print("=" * 79) |
|
|
|
|
|
|
|
|
|
|
|
start = time.time() |
|
|
async with trio.open_nursery() as nursery: |
|
|
async with trio.open_nursery() as nursery: |
|
|
for padid in padids: |
|
|
for padid in padids: |
|
|
nursery.start_soon(handle_pad, args, padid, data, info, session) |
|
|
nursery.start_soon(handle_pad, args, padid, data, info, session) |
|
|
|
|
|
end = time.time() |
|
|
|
|
|
|
|
|
print("=" * 79) |
|
|
print("=" * 79) |
|
|
print("Processed {} pads!".format(len(padids))) |
|
|
print( |
|
|
|
|
|
"Processed {} pads in {} seconds".format( |
|
|
|
|
|
len(padids), round(end - start, 2) |
|
|
|
|
|
) |
|
|
|
|
|
) |
|
|
print("=" * 79) |
|
|
print("=" * 79) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|