
    +d              	       T   d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlZd dl	Z	ddl
mZ ej        Ze j                            e          Z ee j                            edddd                    Zej        d          d	k    Zed
             Zed             Zedd            ZdS )    N)contextmanager   )make_path_posixcliservertestszcatalog1.yml   c               #     K   t          j                    } 	 | V  t          j                            |           rt          j        |            d S d S # t          j                            |           rt          j        |            w w xY w)N)tempfilemkdtempospathexistsshutilrmtree)ds    1lib/python3.11/site-packages/intake/util_tests.pytempdirr      s      A7>>! 	M!	 	27>>! 	M!	s   A 6Bc              #     K   t                      5 }t          j                            |d          }t	          |d          5 }t          j        | |           d d d            n# 1 swxY w Y   |V  d d d            d S # 1 swxY w Y   d S )Nz	conf.yamlw)r   r   r   joinopenyamldump)confr   fnfs       r   	temp_confr   %   s     	 aW\\![))"c]] 	aIdA	 	 	 	 	 	 	 	 	 	 	 	 	 	 		                 s5   1B A$B $A(	(B +A(	,B  BB   c              #     K   ||nt           }t          | | ng           g z   } ||ni }t          ddgt          |           z   |gz   }t          j        ||t          j        t          j                  }|C	 	 t          j        d|z             n)#  t          j
        d           |dz  }|dk    sJ Y nxY wB	 |V  |                                 d S # |                                 w xY w)Nz-mzintake.cli.server)envstdoutstderrTzhttp://localhost:%i/v1/infog?r   )defcatlistex
subprocessPopenPIPESTDOUTrequestsgettimesleep	terminate)argscatr!   waittimeoutcmdps          r   r   r   .   s     
,##fC0b11B6D
(##bCt(
)DJJ
6#
>C#jojFWXXXA #	##:TABBB#
33{"""""	#	s   8B #B5:C C*)NNNNr   )r   r   r'   sysr   r-   
contextlibr   r+   r   utilsr   
executabler&   r   dirname__file__herer   r$   version_infoPY2r   r   r        r   <module>rA      s'   
			      



   % % % % % %   " " " " " "^	wx  	dE8WnUU	V	V	qQ            r@   