reco small fix
This commit is contained in:
parent
2286f1a0ac
commit
3f2663e803
@ -19,8 +19,8 @@ def main(args):
|
|||||||
col = get_mongo_collection(colName, dbName, mongoUri)
|
col = get_mongo_collection(colName, dbName, mongoUri)
|
||||||
batch_size = int(args.batch_size)
|
batch_size = int(args.batch_size)
|
||||||
waves = getWavList(col, batch_size)
|
waves = getWavList(col, batch_size)
|
||||||
print(waves)
|
|
||||||
uris = [w['gcsWawLocation'] for w in waves]
|
uris = [w['gcsWawLocation'] for w in waves]
|
||||||
|
print(uris)
|
||||||
|
|
||||||
start = time.perf_counter()
|
start = time.perf_counter()
|
||||||
with concurrent.futures.ThreadPoolExecutor(max_workers=64) as executor:
|
with concurrent.futures.ThreadPoolExecutor(max_workers=64) as executor:
|
||||||
|
Loading…
Reference in New Issue
Block a user