?g.ddlZddlZddlZddlmZddlmZejdZejdZ d dZ d dZ ddZ dd Z Gd d eZy)N)client) DynamicClientz(.)([A-Z][a-z]+)z([a-z0-9])([A-Z])c j|s tdtjj|s tdtj|Dcgc]_}tjj tjj ||r tjj ||a}}|s tdg}g} |D]%} t|| f|||d|} | j| '|r t|| Scc}w#t$r%} |j| jYd} ~ ed} ~ wwxYw)a Perform an action from files from a directory. Pass True for verbose to print confirmation information. Input: k8s_client: an ApiClient object, initialized with the client args. yaml_dir: string. Contains the path to directory. verbose: If True, print confirmation from the create action. Default is False. namespace: string. Contains the namespace to create all resources inside. The namespace must preexist otherwise the resource creation will fail. If the API object in the yaml file already contains a namespace definition this parameter has no effect. apply: bool. If True, use server-side apply for creating resources. Available parameters for creating : :param async_req bool :param bool include_uninitialized: If true, partially initialized resources are included in the response. :param str pretty: If 'true', then the output is pretty printed. :param str dry_run: When present, indicates that modifications should not be persisted. An invalid or unrecognized dryRun directive will result in an error response and no further processing of the request. Valid values are: - All: all dry run stages will be processed Returns: The list containing the created kubernetes API objects. Raises: FailToCreateError which holds list of `client.rest.ApiException` instances for each object that failed to create. z$`yaml_dir` argument must be providedz/`yaml_dir` argument must be a path to directoryz`yaml_dir` contains no files)verbose namespaceapplyN) ValueErrorospathisdirlistdirisfilejoincreate_from_yamlappendFailToCreateErrorextendapi_exceptions) k8s_clientyaml_dirrrrkwargsifilesfailuresk8s_objects_allfile k8s_objectsfailures V/var/www/openai/venv/lib/python3.12/site-packages/kubernetes/utils/create_from_yaml.pycreate_from_directoryr s/L ?@@ WW]]8 $JKKH% %A 77>>"'',,x3 4  Xq!%   788HO 4* #   K  " "; /)) 5 ,! 4 OOG22 3 3 4sA$C? "D D2 D--D2c R|ffd }Gddtjj}|r |} || S|rRttj j |5} tj| |} || |cdddStd#1swYyxYw)a1 Perform an action from a yaml file. Pass True for verbose to print confirmation information. Input: yaml_file: string. Contains the path to yaml file. k8s_client: an ApiClient object, initialized with the client args. yaml_objects: List[dict]. Optional list of YAML objects; used instead of reading the `yaml_file`. Default is None. verbose: If True, print confirmation from the create action. Default is False. namespace: string. Contains the namespace to create all resources inside. The namespace must preexist otherwise the resource creation will fail. If the API object in the yaml file already contains a namespace definition this parameter has no effect. apply: bool. If True, use server-side apply for creating resources. Available parameters for creating : :param async_req bool :param bool include_uninitialized: If true, partially initialized resources are included in the response. :param str pretty: If 'true', then the output is pretty printed. :param str dry_run: When present, indicates that modifications should not be persisted. An invalid or unrecognized dryRun directive will result in an error response and no further processing of the request. Valid values are: - All: all dry run stages will be processed Returns: The created kubernetes API objects. Raises: FailToCreateError which holds list of `client.rest.ApiException` instances for each object that failed to create. cg}g}|D](}| t| f |d}|j|*|r t||S#t$r%}|j|jYd}~cd}~wwxYw)Nrr)create_from_dictrrrr) objectsrrr yml_documentcreatedrrrrrs r create_withz%create_from_yaml..create_withs #L# 8* (   ""7+$ #H- - % 8 6 677 8s"A A0 A++A0ceZdZejj j jZdevrejdyy) create_from_yaml..Loader=N) __name__ __module__ __qualname__yamlloader SafeLoaderyaml_implicit_resolverscopypoprLoaderr*s="&++"8"8"P"P"U"U"W ) ) # ' ' , *r6r7)r7Nz?One of `yaml_file` or `yaml_objects` arguments must be provided) r/r0r1openr r abspathload_allr ) r yaml_file yaml_objectsrrrrr(r7yml_document_allfs ` `` ` rrrcsZ$),-''- '+,,  "''//), -#}}Qv> /7. - M  . -s ( BB&c g}g}d|dvrU|djdd}|dD]7} |dk7r |d| d<|| d< t|| |f||d|} |j| 9n# t|||f||d|} |j| |r t ||S#tjj $r} |j| Yd} ~ d} ~ wwxYw#tjj $r} |j| Yd} ~ }d} ~ wwxYw)a Perform an action from a dictionary containing valid kubernetes API object (i.e. List, Service, etc). Input: k8s_client: an ApiClient object, initialized with the client args. data: a dictionary holding valid kubernetes objects verbose: If True, print confirmation from the create action. Default is False. namespace: string. Contains the namespace to create all resources inside. The namespace must preexist otherwise the resource creation will fail. If the API object in the yaml file already contains a namespace definition this parameter has no effect. apply: bool. If True, use server-side apply for creating resources. Returns: The created kubernetes API objects. Raises: FailToCreateError which holds list of `client.rest.ApiException` instances for each object that failed to create. Listkinditems apiVersionr#N)replacecreate_from_yaml_single_itemrrrest ApiExceptionr) rdatarrrrrrrA yml_objectr' api_exceptions rr$r$sH6NK fF|##FB/w-Jrz+/ += <(%) 6" 56(   ""7+(( 12D'5>eOUG   w ' // !;;++ 5%%m44 5{{'' 1  ! !- 0 0 1s/"B""CC 0CC D+DDc |d}|durt|jj|d|}|jd|dd|}|rOdj |}t |dr'|d j t |jz }t||S|djd \} } } | d k(r| } d } d j| jd d} d jd| jdD} dj | | j} tt| |} t j#d|}t$j#d|j'}t | dj |r8d|dvr |dd}||d<t| dj |dd|i|}n5|j)ddt| dj |dd|i|}|rOdj |}t |dr'|d j t |jz }t||S)NrATrD) api_versionrAz python-client)body field_managerz {0} created.statusz status='{0}'/rBcorez.k8s.ioc3<K|]}|jywN) capitalize).0words r z/create_from_yaml_single_item..sC2B$DOO%2Bs.z {0}{1}Apiz\1_\2zcreate_namespaced_{0}rmetadatarNz create_{0}r5)r resourcesgetserver_side_applyformathasattrstrrPprint partitionrrsplitsplitrVgetattrrUPPER_FOLLOWED_BY_LOWER_REsub!LOWER_OR_NUM_FOLLOWED_BY_UPPER_RElowerr4)rrJrrrrA apply_clientrespmsggroup_version fcn_to_callk8s_apirs rrFrFsd f D }$Z0::>>"<0t? .|-- ? >D   ''-CtX&--c$++.>?? #J "<0::3?E1g"} GGELLA. /E GGC%++c2BC CE$$UG,>,>,@AK*gfk*:6G % ) )(D 9D , 0 04 @ F F HDw/66t<= *Z0 0":.{;I"+F; Eww 7 > >t DE  %   ;%:ww 3 3D 9:  % ##D) 4 " ?))#dkk*:; ;C c Kr6ceZdZdZdZdZy)rzc An exception class for handling error if an error occurred when handling a yaml file. c||_yrU)r)selfrs r__init__zFailToCreateError.__init__;s ,r6c~d}|jD]+}|dj|j|jz }-|S)NrBzError from server ({0}): {1})rr_reasonrN)rurmrKs r__str__zFailToCreateError.__str__>sG!00M 188$$m&8&8 C1 r6N)r,r-r.__doc__rvryr5r6rrr5s -r6r)NFdefaultF)NNFr{F)Fr{F)FF)r rer/ kubernetesrkubernetes.dynamic.clientrcompilergrir rr$rF Exceptionrr5r6rrs  3'RZZ(:;$.BJJ/B$C!JOET   R lAFBL275p r6