pyranges.multithreaded

Module Contents

Classes

suppress_stdout_stderr

A context manager for doing a "deep suppression" of stdout and stderr in

Functions

get_n_args(f)
call_f(f, nparams, df, odf, kwargs)
call_f_single(f, nparams, df, **kwargs)
merge_dfs(df1, df2)
process_results(results, keys)
make_sparse(df)
make_binary_sparse(kwargs, df, odf)
make_unary_sparse(kwargs, df)
ray_initialized()
get_multithreaded_funcs(function, nb_cpu)
pyrange_apply(function, self, other, **kwargs)
pyrange_apply_single(function, self, **kwargs)
_lengths(df)
_tss(df, **kwargs)
_tes(df, **kwargs)
_extend(df, **kwargs)
pyrange_apply_chunks(function, self, as_pyranges, **kwargs)

Attributes

ray

pyranges.multithreaded.ray

pyranges.multithreaded.get_n_args(f)

pyranges.multithreaded.call_f(f, nparams, df, odf, kwargs)

pyranges.multithreaded.call_f_single(f, nparams, df, **kwargs)

class pyranges.multithreaded.suppress_stdout_stderr

Bases: object

A context manager for doing a “deep suppression” of stdout and stderr in Python, i.e. will suppress all print, even if the print originates in a compiled C/Fortran sub-function.

This will not suppress raised exceptions, since exceptions are printed

to stderr just before a script exits, and after the context manager has exited (at least, I think that is why it lets exceptions through).

__enter__(self)

__exit__(self, *_)

pyranges.multithreaded.merge_dfs(df1, df2)

pyranges.multithreaded.process_results(results, keys)

pyranges.multithreaded.make_sparse(df)

pyranges.multithreaded.make_binary_sparse(kwargs, df, odf)

pyranges.multithreaded.make_unary_sparse(kwargs, df)

pyranges.multithreaded.ray_initialized()

pyranges.multithreaded.get_multithreaded_funcs(function, nb_cpu)

pyranges.multithreaded.pyrange_apply(function, self, other, **kwargs)

pyranges.multithreaded.pyrange_apply_single(function, self, **kwargs)

pyranges.multithreaded._lengths(df)

pyranges.multithreaded._tss(df, **kwargs)

pyranges.multithreaded._tes(df, **kwargs)

pyranges.multithreaded._extend(df, **kwargs)

pyranges.multithreaded.pyrange_apply_chunks(function, self, as_pyranges, **kwargs)