IiSSKJr SSKrSSKrSSKrSSKJr SSK7 SSKJ r SSK 7 SSK J r SSK 7 SSKJr \"5rS rS r\S 4S jr"S S5rg))absolute_importN)util)*) cur_context) kind_matches)selectorc[U[5(a#[URR 55$[U[ 5(a[UR 55$[U[ 5(a'/nUHnUR[U55 M U$[U[5(aU$[SR[U555e)a1 Converts objects into their python primitive form. e.g. - APIObject or Model -> dict - list -> list If the object is already a primitive, it will be returned without error. :param obj: The object to transform into its primitive form :return: The primitive form of the object z&Unknown how to transform into dict: {}) isinstance APIObject_obj_to_primitivemodel _primitiveModellistappenddict ValueErrorformattype)objles @/venv/lib/python3.13/site-packages/openshift_client/apiobject.pyr r s#y!! !5!5!788#u !122#t A HH&q) *#t =DDT#YO PPc[U[[45(aU$[U[5(a [U5$[U5$)z :param obj: The object to return as a Model :return: Return the object as a Model. If object is already a Model, just returns it. )r r ListModelr)rs r _as_modelr/s> #y)** #t~ :rFc~U[LdUS:XaU[La [U5eU$U(aUR5nU$)N)Missing_DEFAULT ModelErrorlower)valerr_msg if_missing lowercases r _access_fieldr)>s= g~  !W% %  iik Jrc\rSrSrS3SjrSrS4SjrS\4SjrS\4Sjr S\4S jr S S\4S jr S r \4S jr \4Sjr\4Sjr\4Sjr\4SjrSrSrS5SjrSr\\4SjrS6SjrS6SjrS6SjrS7SjrS8Sjr\R:S S SSSSS4SjrS9SjrS6Sjr S:S jr!S!r"S;S"jr#S6S#jr$SS)jr*S*r+S+r,S,r-S-r.S.r/S?S/jr0S0r1S1r2S2r3g)@r MNcUbrUR5nUS:XaSS0/S.nOTURS5(a[RU5nO(SU;a[R "U5nO [ S5e[U5Ul[R"U(aUO [55Ul URURR5URl g)Nr v1List) apiVersionkindmetadataitems{ z1Unable to detect markup format (not yaml or json))strip startswithjsonloadsyaml safe_loadrrrcopyrcontext namespace project_name)self dict_to_modelstring_to_modelr<s r__init__APIObject.__init__Os  &-335O"$#'" " ! !++C00 $ ? ; ( $ ?  !TUU=) yyGG $(NN4<<3L3L$M !rc6URR5$)z :return: Returns a python dict representation of the APIObject. Changes are not communicated back to this APIObject's model. )rrr?s ras_dictAPIObject.as_dictms zz$$&&rcv[RURR5US9R 5$)z8 :return: Returns a JSON presentation of the APIObject. indent)r7dumpsrrr5)r?rJs ras_jsonAPIObject.as_jsonts-zz$**//1&zAGGIIrTc@[URRSX!S9$)ad Return the API object's kind if it possesses one (if you want group information included, use qkind). If it does not, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if kind is not present in Model. :param lowercase: Whether kind should be returned in lowercase. :return: The kind or if_missing. z#Object model does not contain .kindr'r()r)rr0r?r(r's rr0APIObject.kindzs"TZZ__Bzp prc ZSRURX!S9URSSUS9S9$)aB Return the API object's qualified kind (e.g. kind[.group]). If kind is not defined, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if kind is not present in Model. :param lowercase: Whether kind should be returned in lowercase. :return: The kind or if_missing. z {kind}{group}rOTr ) prefix_dotr'r()r0group)rr0rTrPs rqkindAPIObject.qkinds?%%499 9+`,0JJ$SUajJ,k&m mrc@[URRSX!S9$)a; Return the API object's apiVersion if it possesses one. If it does not, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if apiVesion is not present in Model. :param lowercase: Whether kind should be returned in lowercase. :return: The kind or if_missing. z)Object model does not contain .apiVersionrOr)rr/rPs rr/APIObject.apiVersions%TZZ22HU_v vrFcURUSS9nUcU[La [S5eU$SU;agURS5SnU(aSR U5$U$)a= Return the API object's group if it possesses an apiVersion field. If it does not contain apiVersion field, returns if_missing. When if_missing not specified, throws a ModelError. If apiVersion is a non-group version, an empty string is returned. :param prefix_dot: Returns '.[group]' for resources with groups, but '' for those without. Convenience for appending to grouped/ungrouped resource names. :param if_missing: Value to return if apiVesion is not present in Model. :param lowercase: Whether kind should be returned in lowercase. :return: The kind or if_missing. N)r(r'z#Unable to find apiVersion in object/r rz.{})r/r"r#splitr)r?rSr(r'r/rTs rrTAPIObject.groupso__yT_J  X% !FGG!! j   %a( <<& & rc6[UR5U5$)z apiobj.is_kind('pod') or apiobj.is_kind(['pod', 'ds']) :param test_kind_or_kind_list: A str or list of strings to match :return: Returns whether this apiobj represents the specified kind or list of kings. )rr0)r?test_kind_or_kind_lists ris_kindAPIObject.is_kinds DIIK)?@@rcV[URRRSUSS9$)z Return the API object's .metadata.uid if it possesses one. If it does not, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if uid is not present in Model. :return: The name or if_missing. z+Object model does not contain .metadata.uidFrO)r)rr1uidr?r's rrc APIObject.uids,TZZ0044JWa',. .rcV[URRRSUSS9$)a Return the API object's .metadata.resourceVersion if it possesses one. If it does not, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if resourceVersion is not present in Model. :return: The name or if_missing. z7Object model does not contain .metadata.resourceVersionFrO)r)rr1resourceVersionrds rresource_versionAPIObject.resource_versions,TZZ00@@Vcm',. .rcB[URRSUSS9$)z Return the API object's apiVersion if it possesses one. If it does not, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if apiVersion is not present in Model. :return: The name or if_missing. z(Object model does not contain apiVersionFrOrXrds r api_versionAPIObject.api_versions&TZZ22GT^',. .rcV[URRRSUSS9$)z Return the API object's .metadata.name if it possesses one. If it does not, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if name is not present in Model. :return: The name or if_missing. z,Object model does not contain .metadata.nameFrO)r)rr1namerds rrnAPIObject.names,TZZ0055KXb',. .rcV[URRRSUSS9$)z Return the API object's namespace if it possesses one. If it does not, returns if_missing. When if_missing not specified, throws a ModelError. :param if_missing: Value to return if namespace is not present in Model. :return: The namespace or if_missing. z1Object model does not contain .metadata.namespaceTrO)r)rr1r=rds rr=APIObject.namespaces,TZZ00::P]g'+- -rcSRURSS9URSS9UR5UR 5S9$)z This name is not useful programmaticaly against the openshift API. It is useful only to determine if two apiObjects appear to represent the same resource. :return: Returns the fully qualified name of the object (ns:apiVersion.kind/name). z{ns}:{kind}{group}/{name}r r'T)rS)nsrTr0rn)rr=rTr0rnrEs rfqnameAPIObject.fqnamesI +11T^^r^5R8< d 8S7;yy{7;yy{24 4rcJUR5S-UR5-$)zH :return: Returns the qualified name of the object (kind[.group]/name). r[)rUrnrEs rqnameAPIObject.qnames zz|c!DIIK//rc *UR5n[5nUR/SQ5 [U5nUR [ UR XU/X@RSS9S95 U(a URSRU55 U$)z :param verb: The verb to execute :param auto_raise: If True, any failed action will cause an exception to be raised automatically. :param cmd_args: An optional list of additional arguments to pass on the command line :return: The Result :rtype: Result )-o=name-f-Nrs)cmd_args stdin_objr=zError during object {}) rFrextendResult add_action oc_actionr<r=fail_ifr)r?verb auto_raiser~content base_argsresults r_object_def_actionAPIObject._object_def_actions,,.F /0)DLL$XAV.5[_A`b c  NN3::4@ A rcF[UR5URS9$)z> :return: Returns a selector that selects this exact receiver static_context)r rxr<rEs r self_selectorAPIObject.self_selectors T\\BBrcUR5R5S:HnSnU(aU[LaU"U5nX44$U[LaU"U5nX44$)a Returns whether the specified object exists according to the API server. If a function is supplied, it will be executed if the object exists. :param on_exists_func: The function to execute if the object exists :param on_absent_func: The function to execute if the object does not exist :return: Boolean indicated whether the object exists, followed by return value of function, if present rN)rcount_existingr")r?on_exists_funcon_absent_func does_existrets rexistsAPIObject.exists$s`'')88:a?  X-$T*8 + &Crc"URSUS9$)z Creates the modeled object if possible. :param cmd_args: An optional list of additional arguments to pass on the command line :return: A Result object :rtype: Result creater~rr?r~s rrAPIObject.create7s&&x(&CCrc"URSUS9$)z Replaces the modeled object if possible. :param cmd_args: An optional list of additional arguments to pass on the command line :return: A Result object :rtype: Result replacerrrs rrAPIObject.replace@s&&y8&DDrcB^^TRUU4SjUU4SjS9up#U$)z Replaces the modeled object if it exists; creates otherwise. :param cmd_args: An optional list of additional arguments to pass on the command line :return: A Result object :rtype: Result c">TRTS9$Nr)rr~r?sr-APIObject.create_or_replace..Pst||X|7Vrc">TRTS9$r)rrsrrrQst{{H{7Ur)rr)r)r?r~_actions`` rcreate_or_replaceAPIObject.create_or_replaceIs(KK/V/U W  rc .[S5nUR[URSUR 5/UR SS9S95 U(aUR S5 UR5S-UR5-R5$)z :param auto_raise: If True, returns empty string instead of throwing an exception if describe results in an error. :return: Returns a string with the oc describe output of an object. describeNrsr~r=zError describing objectr4) rrrr<rxr=routerrr5)r?rrs rrAPIObject.describeUsy :  Yt||Z4::<.)-4)HJ K  II/ 0$(//11rc0nSn [5n U(aU RS5 U(a U RSRU55 U(a U RSRU55 U(aU RS5 U RSRU55 /n [UR 5S5(aU RU5 GO&[UR 5SS /5(a"U R UR S55 GO[UR 5S 5(a:UR S 5H#n U R U R S55 M% GO[UR 5S 5(a:UR S 5H#n U R U R S55 M% GO1[UR 5S S /5(a!U R UR S55 O[UR 5SS/5(aK[URSXUR5/URSS9S9nU "XR5U5 OU(a|U R UR S55 U (dK[URSXUR5/URSS9S9nU "XR5U5 O [5$U HnURRRHn[URSXUR5SUR SRUR55/SS9nSRUR5UR5UR 5nU "UUU5 M M U$)a Attempts to collect logs from running pods associated with this resource. Supports daemonset, statefulset, deploymentconfig, deployment, replicationcontroller, replicationset, buildconfig, build, pod. If a resource is associated with many pods, all pods owned by that resource will be individually scraped for logs. For example, if a daemonset is specified, an invocation of `oc logs ...` will be made for each pod associated with that daemonset -- this is different from the output of `oc logs ds/name`. If try_longshots==True, logs can also be collected to for any object which directly owns pods or responds successfully with "oc logs kind/name". Since pods can be pending or otherwise unable to deliver logs, if an error is encountered during an 'oc logs' invocation, the stderr will be considered the 'logs' of the object. In other words, oc returning an error will not terminate this function. :param cmd_args: An optional list of additional arguments to pass on the command line :param try_longshots: If True, an attempt we will be made to collect logs from resources which the library does not natively understand to possess logs. If False and the object is not recognized, an empty dict will be returned. :return: Returns a dict of { -> }. The fully qualified name will be a human readable, unique identifier containing namespace, object, and container-name (when applicable). cURnURS:wa)USRURUR5- nUR 5R SS5nX0U'g)Nrz. >>>>Error during log collection rc={}<<<< {} z r4)rstatusrrr5r) collection entry_keyrentrys r add_entry!APIObject.logs..add_entrys]JJE}}!MTTU[UbUbdjdndnooKKM))&$7E$)y !r-pz --since={}z--limit-bytes={}z --timestampsz --tail={}podds statefulset deploymentrsdcrcbcbuildlogsNrsrz-cz--namespace={}T)r~ no_namespacez {}->{}({}))rrrrr0r get_ownedrr<rxr=rurrspec containersrn)r? timestampsprevioussince limit_bytestailr~ try_longshotslog_aggregationrrpod_listrrrr containerkeys rrAPIObject.logsds8 *F    T "    \007 8    /66{C D    ^ ,++D12  U + + OOD ! $))+m'< = = OODNN51 2 $))+| 4 4nnT* U 34+$))+t , ,nnT* U 34+$))+d| 4 4 OODNN51 2 $))+g 7 7t||VyTXT^T^T`>a)-4)HJF o{{}f =u 56&t||Vy\`\f\f\hFi1541PRFo{{}fE 6MC YY^^66 "4<<-6#))+tU^UcUc-=-D-DS]]_-U-W04% #))$++-innU/377rc R[R"UURX#XEXhUS95 g)a  Pretty prints logs from selected objects to an output stream (see logs() method). :param stream: Output stream to send pretty printed report (defaults to sys.stderr).. :param cmd_args: An optional list of additional arguments to pass on the command line :return: n/a )rrrrrrr~N)r print_logsr) r?streamrrrrrr~rs rrAPIObject.print_logss0  ZRW'+S["] ^rc [S5nSn[[[US-555HnU"U40UD6nUSLa XV4$[ UR SSSU/UR SS9UR5US:HS 9n URU 5 U RS:XaS n XV4$US:wdM}UR5 M XV4$) a) Calls the modifier_func with self. The function should modify the model of the apiobj argument and return True if it wants this method to try to apply the change via the API. For robust implementations, a non-zero number of retries is recommended. :param modifier_func: Called before each attempt with a self. The associated model will be refreshed before each call if necessary. If the function finds changes it wants to make to the model, it should make them directly and return True. If it does not want to make changes, it should return False. :param cmd_args: An optional list of additional arguments to pass on the command line :param retries: The number of times to retry. A value of 0 means only one attempt will be made. :param kwargs: keyword arguments passed directly into modifier_func :return: A Result object containing a record of all attempts AND a boolean. The boolean indicates True if a change was applied to a resource (i.e. it will be False if modifier_func suggested no change was necessary by returning False). :rtype: Result, bool applyFrr|r}Nrsr)r~r=r last_attemptT) rreversedrrangerr<r=rFrrrefresh) r? modifier_funcretriesr~kwargsrapplied_changeattemptdo_apply apply_actions rmodify_and_applyAPIObject.modify_and_applys" 7OU7Q;%7 89G$T4V4H5    %T\\7dCQYEZ/3~~~/NZ^ZfZfZh3:a<BL LL &""a'!%   !| ):,  rc.URSSUS9up#U$)ar Applies any changes which have been made to the underlying model to the API. You should use modify_and_apply for robust code if the targeted API object may have been updated between the time this APIObject was created and when you call apply. :param cmd_args: An optional list of additional arguments to pass on the command line :return: A Result object :rtype: Result cg)NT)rs rr!APIObject.apply.. strr)rr~)r)r?r~rrs rrAPIObject.applys"$$^Q$Rrc [S5nS/nUSLaURS5 UR[URSUR 5XB/UR SS9S95 URS5 U$) z :param ignore_not_found: If true, no error will be raised if the object cannot be found. :param cmd_args: An optional list of additional arguments to pass on the command line :return: deleter{T--ignore-not-foundNrsrzError deleting object)rrrrr<rxr=r)r?ignore_not_foundr~rrs rrAPIObject.deletesy 8 K t #   1 2 Yt||X)-y(K)-4)HJ K )*rc [S5nS/n[[[S555Hn[ UR SUR 5U/URSS9US:HS9nURU5 URS:Xa/[[RUR55Ul O[R!S 5 M UR#S 5 U$) z] Refreshes this APIObject's cache of the object it represents from the server. :return: self r-o=json getNrsrr~r=rrzError refreshing object content)rrrrrr<rxr=rrrr7r8rrtimesleepr)r?rrrr_actions rrAPIObject.refresh"s 9 K U1X/G u+/::<*C+/>>T>+J/6!|>H LL "!#"4::hll#;<  JJqM0 34 rc |[S5nSS/n[[[S555Hn[ UR SUR 5U/URSS9US:HS 9nURU5 URS:Xat[URS 9nURS 5(aGUR5(d2U(a g[S RUR!55U5eUs $["R%S 5 M [SRUR!55U5e)a Uses the receiver's fully qualified name to query the server for an up-to-date copy of the object. :return: A new copy of APIObject with up-to-date content. If not found, ignore_not_found will cause None to be returned; otherwise, an exception will be thrown. currentrrrrNrsrrrArz7Unable to retrieve current copy of {}; resource missingrz1Unable to retrieve current copy of {}; api errors)rrrrrr<rxr=rrr rr`elementsOpenShiftPythonExceptionrrurr)r?rrrrr new_apiobjs rrAPIObject.current:s" 9  45 U1X/G u+/::<*C+/>>T>+J/6!|>H LL "!#&x||D %%f--j6I6I6K6K'#23l3s3stxttuB4CEFGG!! JJqM!0$''Z'a'abfbmbmbo'p'(* *rcbURRRUnU[LaU$U$)z :param name: The name of the label :param if_missing: Value to return if the label is not present (defaults to None). :return: Returns the value of the specified label or the specified default if not present. )rr1labelsr!r?rnr'vs r get_labelAPIObject.get_labelXs1 JJ   & &t , G HrcpUR5RXUS9nU(aUR5 U$)a" Sends a request to the server to label this API object. :param labels: A dictionary of labels to apply to the object. If value is None, label will be removed. :param overwrite: Whether to pass the --overwrite argument. :param cmd_args: An optional list of additional arguments to pass on the command line :param refresh_model: Whether to refresh apiobject model after label is applied. :return: Result r)rlabelr)r?r overwriter~ refresh_modelrs rr APIObject.labelds3##%++F+Q  LLN rcbURRRUnU[LaU$U$)z :param name: The name of the annotation :param if_missing: Value to return if the annotation is not present (defaults to None). :return: Returns the value of the specified annotation or the specified default if not present. )rr1 annotationsr!rs rget_annotationAPIObject.get_annotationss1 JJ   + +D 1 G HrcpUR5RXUS9nU(aUR5 U$)a" Sends a request to the server to annotate this API object :param annotations: A dictionary of annotations to apply to the object. If value is None, annotation will be removed. :param overwrite: Whether to pass the --overwrite argument. :param cmd_args: An optional list of additional arguments to pass on the command line :param refresh_model: Whether to refresh apiobject model after label is applied. :return: Result )rr r~)rannotater)r?rr r~r rs rrAPIObject.annotates4##%..;fn.o  LLN rc n[S5n[5nURSU-5 URUR55 [R USS9nURSU-5 UR [URSXS/URSS9S95 URS5 U$)Npatchz--type=rIz--patch=rsrzError running patch on objects) rrrrxr7rKrrr<r=r)r? patch_dictstrategyr~rr patch_defs rrAPIObject.patchs 7OF X-.&JJz$J7 i/0 Yt||W ?T)-4)HJ K 23rcURSS9nURS5(aUSSnOU/$/nURSHFnUR5nU(aX6S'Ub U"U5nO [ U5nUR U5 MH U$)a :param cls A custom subclass of APIObject to return in place of APIObjects :return: Returns a python list of APIObjects. If receiver is an OpenShift 'List', each element will be added to the returned list. If the receiver is not of kind List, the [self] will be returned. F)r(r.Nr2r0)r0endswithrrr r)r?cls self_kind item_kindrrdrs rrAPIObject.elementss III.   f % %!I6M G$A A %& !fl HHSM% rc Uc0nURR5n[5nURS5 UR 5H-upVURS5 URUS-U-5 M/ [ S5nUR [URSSSXB/US95 URS5 [UR5S 9R5$) a3 Assumes this APIObject is a template and runs oc process against it. :param parameters: An optional dict of parameters to supply the process command :param cmd_args: An optional list of additional arguments to pass on the command line :return: A list of apiobjects resulting from processing this template. rr=processr|r})r~rzError processing templater) rrrrr2rrrr<rr rr)r? parametersr~templaterkrrs rr&APIObject.processs  J::((*F #$$&DA   T "   QWq[ )' 9  Yt||Y$YAamuvw -.1::<   SXX . .499;#((3Jt~~O_cfcpcpOprcb^^/mUU4Sjn[UTRS9RU5 T$)z Returns a list of apiobjects which are declare an object of this kind/name as their owner. :param find_kind: The kind to check for ownerReferences :return: A (potentially empty) list of APIObjects owned by this object cV>TRU5(aTRU5 ggN)r1r)r/ownedr?s rcheck_owned_by_me.APIObject.get_owned..check_owned_by_mes#}}V$$ V$%rr)r r<for_each)r? find_kindr;r:s` @rrAPIObject.get_owned s0 % 4<<8AABST rc^^[TR5SS/5(a[S5R5$/mUU4Sjn[STRS9R U5 T$)z Returns a list of apiobjects events which indicate this object as their involvedObject. This can be an expensive if there are a large number of events to search. :return: A (potentially empty) list of event APIObjects projectr=eventscV>TRU5(aTRU5 ggr9)r5r)r/involvedr?s rcheck_if_involved/APIObject.get_events..check_if_involved+s%!!&))'*rr)rr0r objectsr<r=)r?rErDs` @r get_eventsAPIObject.get_eventss\  i%= > >H%--/ / ( $,,7@@ARSrc`0nUR5nUR5n[US5(a,[US5(a[SSSUR50S9$UR S5(aXBS'OUR S5(aXBS'OUR S5(aXBS'OkUR S 5(aXBS 'OPUR S 5(aXBS 'O5UR S 5(aXBS'O[ SR X55e[XURS9$)a Returns a dynamic selector which all of a the specified kind of object which is related to this object. For example: - if this object is a node, and find_kind=='pod', it will find all pods associated with the node. - if this object is a template and find_kind=='buildconfig', it will select buildconfigs created by this template. - if this object is a buildconfig and find_kind='builds', builds created by this buildconfig will be selected. :return: A selector which selects objects of kind find_kind which are related to this object. noderTz spec.nodeName)all_namespacesfield_selectorsr(deploymentconfigr buildconfigzopenshift.io/build-config.namerz"statefulset.kubernetes.io/pod-namejobzjob-namez7Unknown how to find {} resources to related to kind: {})rr)r0rnrr r6rrr<)r?r>r this_kindrns rrelatedAPIObject.related3s)IIK yy{  6 * *|Iu/M/ME+/-B C 6N dllFgzz|TS^5_ %41P R S  II9@@{[\~_`_g_g_iklkpkpkrs urcURRRURRURS.$)z Custom serializer for pickle module. The pickle module implements binary protocols for serializing and de-serializing a Python object structure. More info here: https://docs.python.org/3/library/pickle.html#object.__getstate__ )rnr0r<)rr1rnr0r<rEs r __getstate__APIObject.__getstate__{s3JJ'',,JJOO||  rcUS [USSUS35R5nURUS9 SSS5 g!,(df  g=f)z Custom de-serializing for pickle module. The pickle module implements binary protocols for serializing and de-serializing a Python object structure. More info here: https://docs.python.org/3/library/pickle.html#object.__setstate__ r<r0r[rnrN)r object_jsonrB)r?staters r __setstate__APIObject.__setstate__sL 9 vqv@AMMOF MM&M 1  s 4A A)r<r)NNN))TNr9)T)FFNNrNT)N)FN)F)TNT) strategicN)NN)NNNT)4__name__ __module__ __qualname____firstlineno__rBrFrLr"r0rUr/rTr`rcrhrkrnr=rurxrrrrrrrrsysstderrrrrrrrrr rrrrr&r1r5rrHrRr[r^rc__static_attributes__rrrr r MsQN<'J "h p#x m$(H v %8A& .+3 .&. .' .$, - 40 ,C %-X&DE  2fjeN!$ uuTXfjqs  ^*!X &0*<     @=4.4&,(OT<  2rr ) __future__rr;rlr9r rrr<rrnamingrrr objectr"r rr)r rrrrrsP&    8Q8 ,4u B 2B 2r