@@ -367,7 +367,7 @@ def processing_finished(future):
367
367
368
368
369
369
def autoprocess (
370
- parallel = 1 , failed_processing = False , maxtasksperchild = 7 , memory_debugging = False , processing_timeout = 300 , debug : bool = False
370
+ parallel = 1 , failed_processing = False , maxtasksperchild = 7 , memory_debugging = False , processing_timeout = 300 , debug : bool = False , disable_memory_limit : bool = False
371
371
):
372
372
"""
373
373
Automatically processes analysis data using a process pool.
@@ -392,7 +392,8 @@ def autoprocess(
392
392
# pool = multiprocessing.Pool(parallel, init_worker)
393
393
pool = False
394
394
try :
395
- memory_limit ()
395
+ if not disable_memory_limit :
396
+ memory_limit ()
396
397
log .info ("Processing analysis data" )
397
398
with pebble .ProcessPool (max_workers = parallel , max_tasks = maxtasksperchild , initializer = init_worker ) as pool :
398
399
# CAUTION - big ugly loop ahead.
@@ -604,6 +605,7 @@ def main():
604
605
default = False ,
605
606
required = False ,
606
607
)
608
+ parser .add_argument ("--disable-memory-limit" , help = "Disable memory limit." , action = "store_true" , default = False , required = False )
607
609
args = parser .parse_args ()
608
610
609
611
init_database ()
@@ -617,6 +619,7 @@ def main():
617
619
memory_debugging = args .memory_debugging ,
618
620
processing_timeout = args .processing_timeout ,
619
621
debug = args .debug ,
622
+ disable_memory_limit = args .disable_memory_limit ,
620
623
)
621
624
else :
622
625
for start , end in args .id :
0 commit comments