motion correction wip
@@ -230,6 +230,10 @@ def write_binary_recording(recording, file_paths=None, dtype=None, add_file_exte
# use executor (loop or workers)
func = _write_binary_chunk
init_func = _init_binary_worker
+ n_jobs = ensure_n_jobs(recording, n_jobs=job_kwargs.get('n_jobs', 1))
+ if n_jobs == 1:
+ init_args = (recording, rec_memmaps_dict, dtype)
+ else:
init_args = (recording.to_dict(), rec_memmaps_dict, dtype)
executor = ChunkRecordingExecutor(recording, func, init_func, init_args, verbose=verbose,
job_name='write_binary_recording', **job_kwargs)
