U
    Nvf                     @   sX   d dl Z d dlZd dlmZ d dlmZ dd Zedd Zedd	 Zed
d Z	dS )    N)check_subprocess_call)with_multiprocessingc                   C   s   t tdstdd S )N__version__z6There are no __version__ argument on the joblib module)hasattrjoblibAssertionError r   r   ;/tmp/pip-unpacked-wheel-dylwa62s/joblib/test/test_module.pytest_version   s    r
   c                  C   s   d} t tjd| g d S )Nzif True:
        import joblib
        import multiprocessing as mp
        # The following line would raise RuntimeError if the
        # start_method is already set.
        mp.set_start_method("loky")
    -cr   sys
executablecoder   r   r	   *test_no_start_method_side_effect_on_import   s    r   c                  C   s.   d} t jdkr| dd} tt jd| g d S )NaJ  if True:
        import joblib
        from multiprocessing import semaphore_tracker
        # The following line would raise RuntimeError if the
        # start_method is already set.
        msg = "multiprocessing.semaphore_tracker has been spawned on import"
        assert semaphore_tracker._semaphore_tracker._fd is None, msg)      Zsemaphore_trackerZresource_trackerr   )r   version_inforeplacer   r   r   r   r   r	   #test_no_semaphore_tracker_on_import   s    
r   c                  C   s   d} t tjd| g d S )NaN  if True:
        import joblib
        from joblib.externals.loky.backend import resource_tracker
        # The following line would raise RuntimeError if the
        # start_method is already set.
        msg = "loky.resource_tracker has been spawned on import"
        assert resource_tracker._resource_tracker._fd is None, msg
    r   r   r   r   r   r	   "test_no_resource_tracker_on_import+   s    r   )
r   r   Zjoblib.testingr   Zjoblib.test.commonr   r
   r   r   r   r   r   r   r	   <module>   s   

