FM / joblib

/usr/local/lib/python3.6/site-packages/joblib/

/usr/local/lib/python3.6/site-packages/joblib

Name	Size	Mode	Actions
externals/	-	0755	rm
test/	-	0755	rm
__pycache__/	-	0755	rm
backports.py	2778	0644	edit dl rm
compressor.py	19770	0644	edit dl rm
disk.py	4386	0644	edit dl rm
executor.py	5316	0644	edit dl rm
format_stack.py	1045	0644	edit dl rm
func_inspect.py	13945	0644	edit dl rm
hashing.py	10536	0644	edit dl rm
logger.py	5129	0644	edit dl rm
memory.py	41777	0644	edit dl rm
my_exceptions.py	962	0644	edit dl rm
numpy_pickle.py	23498	0644	edit dl rm
numpy_pickle_compat.py	8548	0644	edit dl rm
numpy_pickle_utils.py	8706	0644	edit dl rm
parallel.py	46946	0644	edit dl rm
pool.py	14334	0644	edit dl rm
testing.py	2180	0644	edit dl rm
_cloudpickle_wrapper.py	376	0644	edit dl rm
_dask.py	12932	0644	edit dl rm
_deprecated_format_stack.py	14505	0644	edit dl rm
_deprecated_my_exceptions.py	4134	0644	edit dl rm
_memmapping_reducer.py	28069	0644	edit dl rm
_multiprocessing_helpers.py	1885	0644	edit dl rm
_parallel_backends.py	23805	0644	edit dl rm
_store_backends.py	14435	0644	edit dl rm
_utils.py	1116	0644	edit dl rm
__init__.py	4993	0644	edit dl rm

Edit: /usr/local/lib/python3.6/site-packages/joblib/testing.py (2180B)

"""
Helper for testing.
"""

import sys
import warnings
import os.path
import re
import subprocess
import threading

import pytest
import _pytest

raises = pytest.raises
warns = pytest.warns
SkipTest = _pytest.runner.Skipped
skipif = pytest.mark.skipif
fixture = pytest.fixture
parametrize = pytest.mark.parametrize
timeout = pytest.mark.timeout
xfail = pytest.mark.xfail
param = pytest.param

def warnings_to_stdout():
    """ Redirect all warnings to stdout.
    """
    showwarning_orig = warnings.showwarning

def showwarning(msg, cat, fname, lno, file=None, line=0):
        showwarning_orig(msg, cat, os.path.basename(fname), line, sys.stdout)

warnings.showwarning = showwarning
    # warnings.simplefilter('always')

def check_subprocess_call(cmd, timeout=5, stdout_regex=None,
                          stderr_regex=None):
    """Runs a command in a subprocess with timeout in seconds.

Also checks returncode is zero, stdout if stdout_regex is set, and
    stderr if stderr_regex is set.
    """
    proc = subprocess.Popen(cmd, stdout=subprocess.PIPE,
                            stderr=subprocess.PIPE)

def kill_process():
        warnings.warn("Timeout running {}".format(cmd))
        proc.kill()

timer = threading.Timer(timeout, kill_process)
    try:
        timer.start()
        stdout, stderr = proc.communicate()
        stdout, stderr = stdout.decode(), stderr.decode()
        if proc.returncode != 0:
            message = (
                'Non-zero return code: {}.\nStdout:\n{}\n'
                'Stderr:\n{}').format(
                    proc.returncode, stdout, stderr)
            raise ValueError(message)

if (stdout_regex is not None and
                not re.search(stdout_regex, stdout)):
            raise ValueError(
                "Unexpected stdout: {!r} does not match:\n{!r}".format(
                    stdout_regex, stdout))
        if (stderr_regex is not None and
                not re.search(stderr_regex, stderr)):
            raise ValueError(
                "Unexpected stderr: {!r} does not match:\n{!r}".format(
                    stderr_regex, stderr))

finally:
        timer.cancel()

""" Helper for testing. """ import sys import warnings import os.path import re import subprocess import threading import pytest import _pytest raises = pytest.raises warns = pytest.warns SkipTest = _pytest.runner.Skipped skipif = pytest.mark.skipif fixture = pytest.fixture parametrize = pytest.mark.parametrize timeout = pytest.mark.timeout xfail = pytest.mark.xfail param = pytest.param def warnings_to_stdout(): """ Redirect all warnings to stdout. """ showwarning_orig = warnings.showwarning def showwarning(msg, cat, fname, lno, file=None, line=0): showwarning_orig(msg, cat, os.path.basename(fname), line, sys.stdout) warnings.showwarning = showwarning # warnings.simplefilter('always') def check_subprocess_call(cmd, timeout=5, stdout_regex=None, stderr_regex=None): """Runs a command in a subprocess with timeout in seconds. Also checks returncode is zero, stdout if stdout_regex is set, and stderr if stderr_regex is set. """ proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE) def kill_process(): warnings.warn("Timeout running {}".format(cmd)) proc.kill() timer = threading.Timer(timeout, kill_process) try: timer.start() stdout, stderr = proc.communicate() stdout, stderr = stdout.decode(), stderr.decode() if proc.returncode != 0: message = ( 'Non-zero return code: {}.\nStdout:\n{}\n' 'Stderr:\n{}').format( proc.returncode, stdout, stderr) raise ValueError(message) if (stdout_regex is not None and not re.search(stdout_regex, stdout)): raise ValueError( "Unexpected stdout: {!r} does not match:\n{!r}".format( stdout_regex, stdout)) if (stderr_regex is not None and not re.search(stderr_regex, stderr)): raise ValueError( "Unexpected stderr: {!r} does not match:\n{!r}".format( stderr_regex, stderr)) finally: timer.cancel()