run_parallel

snake.core.parallel.run_parallel(func, input_array, output_array, n_jobs=-1, parallel_axis=0, *args, **kwargs)

Run a function in parallel with shared memory.

Parameters:

• func (Callable)

• input_array (ndarray[Any, dtype[_ScalarType_co]])

• output_array (ndarray[Any, dtype[_ScalarType_co]])

• n_jobs (int)

• parallel_axis (int)

• args (Any)

• kwargs (Any)

Return type:

ndarray[Any, dtype[_ScalarType_co]]