tj.ddlZddlZddlZddlmZddlmZejdZejdZ ddZ dd Z dd Z dd Z Gd d eZdS)N)client) DynamicClientz(.)([A-Z][a-z]+)z([a-z0-9])([A-Z])Fdefaultc stdtjstdfdtjD}|stdg}g}|D][} t || f|||d|} || +#t$r$} || j Yd} ~ Td} ~ wwxYw|rt||S)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 directorycg|]_}tjtj|?tj|`S)ospathisfilejoin).0iyaml_dirs _/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/kubernetes/utils/create_from_yaml.py z)create_from_directory..Fs]    7>>"',,x33 4 4   Xq!!   z`yaml_dir` contains no files)verbose namespaceapplyN) ValueErrorr r isdirlistdircreate_from_yamlappendFailToCreateErrorextendapi_exceptions) k8s_clientrrrrkwargsfilesfailuresk8s_objects_allfile k8s_objectsfailures ` rcreate_from_directoryr&sYL L?@@@ W]]8 $ $LJKKK    H%%   E 97888HO 4 4 4* #   K  " "; / / / /  4 4 4 OOG2 3 3 3 3 3 3 3 3 4*))) s;'B## C-C  Cc h|ffd }Gddtjj}|r |} || S|rhttj|5} tj| |} || |cdddS#1swxYwYdStd)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}||.#t$r$}||jYd}~Wd}~wwxYw|rt||S)Nrr)create_from_dictrrrr) objectsrr!r$ yml_documentcreatedr%rrrrs r create_withz%create_from_yaml..create_withs # 8 8L# 8* (   ""7++++$ 8 8 8 677777777 8  .#H-- -s'6 A$AA$ceZdZejjjZdevreddSdS) create_from_yaml..Loader=N) __name__ __module__ __qualname__yamlloader SafeLoaderyaml_implicit_resolverscopypoprrrLoaderr0sR"&+"8"P"U"U"W"W ) ) ) # ' ' , , , , , * )rr;)r;Nz?One of `yaml_file` or `yaml_objects` arguments must be provided) r5r6r7openr r abspathload_allr) r yaml_file yaml_objectsrrrrr.r;yml_document_allfs ` `` ` rrrcsJZ$),-----'---   '{+,,,  "'//),, - - 8#}Qv>>> ;/77 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 M   s)"BBBc :g}g}d|dvr|ddd}|dD]v} |dkr|d| d<|| d< t|| |f||d|} || A#tjj$r} || Yd} ~ od} ~ wwxYwn_ t|||f||d|} || n6#tjj$r} || Yd} ~ nd} ~ wwxYw|rt ||S)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) rdatarrrrrr$rE yml_objectr- api_exceptions rr*r*s6NK fF|##FB//w- 5 5Jrzz+/ += <(%) 6" 56(   ""7++++;+ 5 5 5%%m44444444 5! 5( 12D'5>eOUG   w ' ' ' '{' 1 1 1  ! !- 0 0 0 0 0 0 0 0 10/// s0 'A44B'B""B','CD(DDc |d}|durt|j|d|}|jd|dd|}|r^d|}t |dr*|d t |jz }t||S|d d \} } } | d kr| } d } d | d d} d d| dD} d| | } tt| |} t d|}t$d|}t | d|rId|dvr|dd}||d<t| d|dd|i|}nA|ddt| d|dd|i|}|r^d|}t |dr*|d t |jz }t||S)NrETrH) api_versionrEz python-client)body field_managerz {0} created.statusz status='{0}'/rFcorez.k8s.ioc3>K|]}|VdSN) capitalize)r words r z/create_from_yaml_single_item..s,CC$DOO%%CCCCCCr.z {0}{1}Apiz\1_\2zcreate_namespaced_{0}rmetadatarRz create_{0}r)r resourcesgetserver_side_applyformathasattrstrrTprint partitionr rsplitsplitrZgetattrrUPPER_FOLLOWED_BY_LOWER_REsub!LOWER_OR_NUM_FOLLOWED_BY_UPPER_RElowerr:)rrNrrrrE apply_clientrespmsggroup_version fcn_to_callk8s_apirs rrJrJs f D }}$Z00:>>"<0t?  .|- ?  >D     ''--CtX&& @--c$+.>.>??? #JJJ "<0::3??E1g"}} GGELLA.. / /E GGCC%++c2B2BCCC C CE$$UG,>,>,@,@AAK*gfk**:66G % ) )(D 9 9D , 0 04 @ @ F F H HDw/66t<<==   *Z0 0 0":.{;I"+F; Eww 7 > >t D DEE   %    ;%%%:ww 3 3D 9 9::   %  ##D)) 4 " " < ?))#dk*:*:;; ;C c KrceZdZdZdZdZdS)rzc An exception class for handling error if an error occurred when handling a yaml file. c||_dSrY)r)selfrs r__init__zFailToCreateError.__init__;s,rcdd}|jD]%}|d|j|jz }&|S)NrFzError from server ({0}): {1})rrbreasonrR)rxrprOs r__str__zFailToCreateError.__str__>sJ!0  M 188$m&8 CC rN)r2r3r4__doc__ryr|rrrrr5s< ---rr)NFrF)NNFrF)FrF)FF)r rer5 kubernetesrkubernetes.dynamic.clientrcompilerjrlr&rr*rJ Exceptionrrrrrs$  333333'RZ(:;;$.BJ/B$C$C!JOEEEET   R R R R lAFBBBBL275555p r