diff --git a/parallelRunAndWrite.py b/parallelRunAndWrite.py index 76b2ffa8c1152765bdec82965ec0cf8ef259f801..546a9b4a87d84ad6589fd86597b8302a8d8ca503 100644 --- a/parallelRunAndWrite.py +++ b/parallelRunAndWrite.py @@ -33,7 +33,7 @@ MAX_PROC = int(mp.cpu_count()) # + If errFileName is not None, all exceptions produced by func are intercepted and gradually logged in errFileName # + numProc sets the number of process to use # + if ordered is true, results are outputed in the same order as tasks -# + chunksize : chunkszise for imap +# + chunksize : chunkszise for imap # + if debug is set to true, errors are also printed to stderr def parallelRunAndWrite(func, tasks, outFileName, bar=True, errFileName=None, numProc=MAX_PROC, ordered=False, chunksize=1, debug=False):