
    Wf	                     t   d dl Z d dlZd dlZd dlZd dlmZmZmZ d dlm	Z	m
Z
 d dlmZ e j                  j                  e      Z G d de	      Z ede       ej$                  d        Z ej$                  d	
      d        Zej$                  d        Zej$                  d        Zej$                  d        Zy)    N)configopen_catalogregister_driver)
DataSourceSchema)copy_test_filec                   ,     e Zd ZdZdZ fdZd Z xZS )
TestSourcetestpythonc                 0    || _         t        | 	          y N)test_kwargssuper__init__)selfkwargs	__class__s     /lib/python3.12/site-packages/intake/conftest.pyr   zTestSource.__init__   s    !    c                     t               S r   )r   )r   s    r   _get_schemazTestSource._get_schema   s	    xr   )__name__
__module____qualname__name	containerr   r   __classcell__)r   s   @r   r
   r
      s    DIr   r
   r   c              #     K   ddl m} d}t        j                  |      } |t        j                  j                  | d            }|t        j                  |<   t        j                         |k(  sJ | t        j                  j                          |r|t        j                  |<   nt        j                  |= t        j                         |k7  sJ y w)Nr   )make_path_posixINTAKE_CONF_FILEztest_config.yml)fsspec.implementations.localr    osgetenvpathjoinenvironr   cfileconfreset)tmp_pathr    keyoriginaltemp_config_paths        r   tmp_config_pathr/   $   s     <
Cyy~H&rww||H>O'PQ&BJJsO<<>----

KK"

3JJsO<<>----s   CCfunction)scopec                     dd l }t        j                  j                         }|j                  j
                  |d<   |j                  j                  d   |d<   |S )Nr   INTAKE_CONF_DIR	cache_dirINTAKE_CACHE_DIR)intaker#   r'   copyr   confdirr)   )
temp_cachetempdirr6   envs       r   r;   r;   6   sI    
**//
C#]]22C$mm00=CJr   c                      t        j                         5 } t        j                  | d      }t	        d|      }t        |      cd d d        S # 1 sw Y   y xY w)Nr6   catalog_inherit_params.ymltempfileTemporaryDirectory	posixpathr&   r   r   tmp_dirr+   target_catalogs      r   inherit_params_catrE   @   sJ    		$	$	& ,'>>'84'(DhON+, , ,s   -AAc                      t        j                         5 } t        j                  | d      }t	        d|       t	        d|       t        |dz         cd d d        S # 1 sw Y   y xY w)Nr6   r=   catalog_nested_sub.ymlz/*.ymlr>   )rC   r+   s     r   inherit_params_multiple_catsrH   H   sX    		$	$	& 1'>>'843X>/:Hx/0	1 1 1s   <AA$c                      t        j                         5 } t        j                  | d      }t	        d|      }t	        d|       t        |      cd d d        S # 1 sw Y   y xY w)Nr6   r=   rG   r>   rB   s      r   inherit_params_subcatrJ   Q   sU    		$	$	& ,'>>'84'(DhO/:N+	, , ,s   9AA!)r#   rA   r?   pytestr6   r   r   r   intake.source.baser   r   intake.tests.test_utilsr   r%   dirname__file__herer
   fixturer/   r;   rE   rH   rJ    r   r   <module>rS      s    
    8 8 1 2	wwx 	 	 
 # . ." j! " , , 1 1 , ,r   