IiYWSSKJr SSKrSSKrSSKJrJr SSKJr SSKJr SSK J r \R"SS5r \R"S S5r \"\R"S S 55r\R"S S 5R!5S;r\R"SS5R!5S;r\R"SS 5R!5S;r\"\R"SS55rSr"SS\5rSrSrSrSrSrSrSrSrSr S\\ S\\S 4S!jr!S"r"S.S#jr#S/S$jr$S%r%S0S&jr&S'r'S(r(S)r)S1S*jr*S+r+"S,S-\5r,\,"5r-g)2)absolute_importN)datetimetimezone) timedelta)local)Result,OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_HOSTNAME,OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_USERNAME(OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_PORT22,OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_AUTO_ADDfalse)yestruety15OPENSHIFT_CLIENT_PYTHON_DEFAULT_LOAD_SYSTEM_HOST_KEYSr'OPENSHIFT_CLIENT_PYTHON_SKIP_TLS_VERIFY&OPENSHIFT_CLIENT_PYTHON_MASTER_TIMEOUTc([RS$)Nr)contextstack>/venv/lib/python3.13/site-packages/openshift_client/context.py cur_contextrs == rc\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrSrSrSrSSjrSrSrSrSrSrSrSrSrg)Context!cPSUlSUlSUlSUlSUlSUlSUlSUlSUlSUl SUl SUl SUl SUl SUlSUlSUlSUlSUlSUlSUlSUl[,R."5Hsn[,R0"US5nU(a2UR2S:Xd UR2R5S5(aMU[,R6"US5Ul g g)NFXTropenshift_clientzopenshift_client.)parentoc_pathkubeconfig_path api_servertoken ca_cert_path project_nameloglevel_valueskip_tls_verifytracking_strategy no_trackingtimeout_datetimeoptions ssh_client ssh_hostnamessh_port ssh_username ssh_password ssh_timeoutssh_auto_add_hostssh_load_system_host_keys frame_infoinspectr getmodule__name__ startswith getframeinfo)selfframemodules r__init__Context.__init__"s  #   "#!%  $     !&)-&]]_E&&uQx0F6??.@@FOOD^D^_rDsDs%2258->T]]]a]n]n-1->->HXHX $ Z557I NN . .y/E/E/G H3 rc`[RR5 UR5 grO)rrpoprQ)rBtypevalue tracebacks r__exit__Context.__exit__xs  rc"UR5$)zN The API has been flagged for deprecation. Please use get_api_server instead )get_api_serverrKs r get_api_urlContext.get_api_url}s""$$rcURb UR$URbURR5$[R$rO)r*r'rtrdefault_api_serverrKs rrtContext.get_api_servers? ?? &?? " ;; ";;--/ /)))rcURb UR$URbURR5$[R$rO)r+r' get_tokenr default_tokenrKs rr{Context.get_tokens? :: !::  ;; ";;((* *$$$rcURb UR$URbURR5$[R$rO)r,r'get_ca_cert_pathrdefault_ca_cert_pathrKs rrContext.get_ca_cert_pathsC    ($$ $ ;; ";;//1 1+++rcURb UR$URbURR5$[R$rO)r(r' get_oc_pathrdefault_oc_pathrKs rrContext.get_oc_paths? << #<<  ;; ";;**, ,&&&rcURb UR$URbURR5$[R$rO)r)r'get_kubeconfig_pathrdefault_kubeconfig_pathrKs rrContext.get_kubeconfig_pathC    +'' ' ;; ";;224 4...rcURb UR$URbURR5$g)z :rtype SSHClient: N)r4r'get_ssh_clientrKs rrContext.get_ssh_clients8 ?? &?? " ;; ";;--/ /rcURb UR$URbURR5$grO)r7r'get_ssh_usernamerKs rrContext.get_ssh_username:    ($$ $ ;; ";;//1 1rcURb UR$URbURR5$grO)r8r'get_ssh_passwordrKs rrContext.get_ssh_passwordrrcURb UR$URbURR5$grO)r5r'get_ssh_hostnamerKs rrContext.get_ssh_hostnamerrcURb UR$URc'URbURR5$[R $rO)r-r*r' get_projectrdefault_projectrKs rrContext.get_projectsN    ($$ $ ?? "t{{'>;;**, ,&&&rNcUc0nUnUR(d UR[R5 OURR US9 UR (aURUR 5 U$)N)add_to)r'updaterdefault_options get_optionsr3)rBr aggregates rrContext.get_optionssf >F {{   W44 5 KK # #9 # 5 <<   T\\ *rcURb UR$URbURR5$[R$rO)r.r' get_loglevelrdefault_loglevelrKs rrContext.get_loglevelsC    *&& & ;; ";;++- -'''rcURb UR$URbURR5$[R$rO)r/r'get_skip_tls_verifyrdefault_skip_tls_verifyrKs rrContext.get_skip_tls_verifyrrc[5n[R"[R5nUb1UR bX!R :aSU4$UR nUbM1g)z :return: Returns any Context which claims it is timed out. Returns (True,Context) if any surrounding timeout context is expired. If not, returns (False,None) T)FN)rrnowrutcr2r')rBcrs rget_out_of_timeContext.get_out_of_timesW Mll8<<(m!!-#8J8J2JQwAmrc[5nSn[R"[R5nSnUbUR bvX1R :aSU4$Uc UR U- R 5nUnO@UR U- R 5U:aUnUR U- R 5nURnUbMUb US:aSU4$X$4$)a' :return: Returns the number of seconds a command needs to finish to satisfy existing timeout contexts and the Context which possessed the minimum; i.e. (secs, Context). A minimum of 1 second is always returned if a timeout context exists. If no timeout context exists, (None,None) is returned. Nr)rrrrrr2 total_secondsr')rBrmin_secsrlimiting_contexts rget_min_remaining_seconds!Context.get_min_remaining_secondss Mll8<<(m!!-+++a4K% ! 2 2S 8GGIH'($((3.==?(J'($ ! 2 2S 8GGIHAm  HqL&& &))rcZ[UR[5(a UR$g)z :return: If this contextmanager was returned by `with tracking()`, returns the Result object which has tracked all internal oc invocations. Otherwise, returns None. N) isinstancer0r rKs r get_resultContext.get_result!s& d,,f 5 5)) )rcUnUbUR(agUR(aL[UR[5(aURR U5 OURU5 UR nUbMggrO)r1r0rr add_actionr')rBactionrs rregister_actionContext.register_action1sd m}}""a116::''226:''/AmrcU(a:US:a4[R"[R5[ US9-UlgSUlg)a Sets the internal timeout for this context the specified number of seconds in the future from the time it is called. Internal use only. :param seconds: The number of seconds from now to start timing out oc invocations. If None, timeout for this context is cleared. :return: N/A r)secondsN)rrrrrr2)rBrs r set_timeoutContext.set_timeout?s5 w{$,LL$>SZA[$[D !$(D !r)r*r,r<r)r.r1r(r3r'r-r/r:r4r5r;r8r6r9r7r2r+r0rO)r? __module__ __qualname____firstlineno__rErLrQrJrqrurtr{rrrrrrrrrrrrrrrr__static_attributes__rrrr!r!!s}#J#IB % *%,'/'((/ *>   )rr!cU[lg)z Sets the default full path of the oc binary to execute for this thread. If no client_path() context is in use, this path will be used. N)rrpaths rset_default_oc_pathrMs #GrcU[lgrO)rrrs rset_default_kubeconfig_pathrUs &*G#rc[U5 g)zV The API has been flagged for deprecation. Please use set_default_api_server instead N)set_default_api_server)urls rset_default_api_urlrZs 3rcU[lgrO)rrx)servers rrras !'GrcU[lgrO)rr)names rset_default_projectres "GrcU[lgrO)rr|vs rset_default_tokenris GrcU[lgrO)rrrs rset_default_loglevelrms  GrcU[lgrO)rr)do_skips rset_default_skip_tls_verifyrqs &-G#rc[5nU$)z :return: Returns a blank context which can be used to temporarily replace a real context in a with statement. Mostly useful for debugging programs without having to tab/untab a large amount of code. )r!rs rblankrus  A Hrr%c[5nUc[nU(a&SU;a URSS5uUlUlO XlX'lXlX7lXglXGlXWl U$)a Will ssh to the specified host to in order to run oc commands. If hostname is not specified, the environment variable OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_HOSTNAME will be used. If the environment variable is not defined, this context will have no effect and the current host will be assumed to be the host on which oc will be run. :param hostname: The hostname or IP address. Defaults to environment variable OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_HOSTNAME if None. If the hostname is of the form 'user@host', the string will be split and the user will take precedence over any argument / environment variable supplied. :param port: The ssh port. Defaults to OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_PORT, then None. :param username: The username to use. Defaults to OPENSHIFT_CLIENT_PYTHON_DEFAULT_USERNAME, then None. :param password: The username's password :param auto_add_host: Whether to auto accept host certificates. Defaults to OPENSHIFT_CLIENT_PYTHON_DEFAULT_SSH_AUTO_ADD, then false. :param load_system_host_keys: Whether load known_hosts. Defaults to DEFAULT_LOAD_SYSTEM_HOST_KEYS, then true. :param connect_timeout: Connection timeout :return: @r) r!DEFAULT_SSH_HOSTNAMEsplitr7r5r6r8r9r:r;)rVrWrXrY auto_add_hostrbconnect_timeoutrs r client_hostr~sb&  A'C8O)1Q)?&!!JN#M'"7 Hrc&[5nXlU$)z Specifies the full path to the oc binary in this context. If unspecified, 'oc' is invoked and it should be in $PATH. :param oc_path: Fully path to executable oc binary :return: )r!r()r(rs r client_pathrs  AI Hrc>[5nX#lXlXlU$)a Establishes a context in which inner oc interactions will target the specified OpenShift API server (--server arguments). Contexts can be nested. The most immediate ancestor cluster context will define the API server targeted by an action. :param api_url: The oc --server argument to use. :param kubeconfig_path: The oc --kubeconfig argument to use. :return: The context object. Can be safely ignored. )r!r)r*r,)api_urlr,r)rs rr*r*s   A'L!N Hrc&[5nXlU$)z Establishes a context in which inner oc interactions will include the specified token on the command line with --token. :param val: The oc --token argument to use. :return: The context object. Can be safely ignored. )r!r+)valrs rr+r+s  AG Hrc^[5nU(dU$URS5SUlU$)a^ Establishes a context in which inner oc interactions will impact the named OpenShift project. project contexts can be nested. The most immediate ancestor project context will define the project used by an action. :param name: The name of the project. If None, parent context project will be used. :return: The context object. Can be safely ignored. /r)r!rr-)rrs rprojectrs.  A ZZ_R(AN Hrc[5nU(a#[U5(d [S5eXlU$[ SU5UlU$)a Establishes a context in which all inner actions will be tracked (unless a inner no_tracking context prevents tracking). Trackers can be nested -- all actions performed within a tracker's context will be tracked unless there is a descendant no_tracking context which blocks tracking from propagating to this ancestor. :param action_handler: If specified, after each oc action is performed, this method will be called with the Action object. If not specified, all Actions will aggregate into a internally managed Result object which can be accessed with get_result. :param limit: If specified, it allows to specify a limit on the number of actions stored by a given tracking context. If not specified or given a value less than 0, it will store unlimited number of oc interactions, and the limit value will be stored in the Result object. :return: The tracker contextmanager. If action_handler is not specified, call get_result to receive a Result object with all tracked Action objects. z&Expected action_handler to be callabletracking)r!callable ValueErrorr0r )action_handlerlimitrs rrrsH(  A''EF F, H%Z7 Hrc([5nSUlU$)a; Prevent outer tracker contexts from registering oc actions in their tracker objects. This is useful when a large amount of data is going to be transferred via stdout/stderr OR when certain actions make carry confidential data that should not appear in trackers. :return: The context object. Can be safely ignored. T)r!r1rs rr1r1s  AAM Hrcp[5n0UlUHnURRU5 M U$)a Establishes a context in which inner oc invocations will be passed an arbitrary set of options. This is most useful in ensuring, for example, that a certain --token, --as, --context, etc, is passed to each oc invocation. Keys should be long form option names, without preceding hyphens. e.g. { 'token': '.....' } . Unlike most other contexts, .options is additive. If on oc invocation is embedded within two .options, it will include both sets. Inner option contexts will override the same key specified at outer levels. A value of None will prevent the option from being passed. Tip for flags: Even flags like --insecure-skip-tls-verify can be specified as key=value: --insecure-skip-tls-verify=true :param args: A vararg list of dicts. Keys in dicts will be pre-pended with '-' if single letter or '--' if multiple letter not already preceded with a hyphen. :return: The context object. Can be safely ignored. )r!r3r)argsrds rr3r3s52  AAI   Hrc&[5nXlU$)a3 Establishes a context in which inner oc interactions will execute with the specified loglevel. loglevel contexts can be nested. The most immediate ancestor loglevel context will define the loglevel used by an action. :param v: The loglevel to use (0-9). :return: The context object. Can be safely ignored. )r!r.)rrs rloglevelr4s  A Hrc2[5nU(+UlU$)z Establishes a context in which inner oc interactions will pass honor/ignore tls verification. :param enable: If false, --insecure-skip-tls-verify will be passed to oc invocations :return: The context object. Can be safely ignored. )r!r/)enablers r tls_verifyrBs  A" A Hrc<[5nURU5 U$)ap Establishes a context in which inner oc interactions must terminate within a specified period. timeout contexts can be nested and each nested layer will be enforced. If actions run longer than the specified timeout, an exception will be thrown. :param seconds: The number of seconds before actions should time out. :return: The context object. Can be safely ignored. )r!r)rrs rrZrZNs  AMM' Hrc\rSrSrSrSrg)ThreadLocalContexti]c[R"SS5Ul[R"SS5Ul[R"SS5UlSUl[R"SS5Ul[R"SS5Ul0Ul[R"SS5Ul [R"SS5Ul [5nUR[5 U/Ulg) N'OPENSHIFT_CLIENT_PYTHON_DEFAULT_OC_PATHoc+OPENSHIFT_CLIENT_PYTHON_DEFAULT_CONFIG_PATH*OPENSHIFT_CLIENT_PYTHON_DEFAULT_API_SERVER,OPENSHIFT_CLIENT_PYTHON_DEFAULT_CA_CERT_PATH'OPENSHIFT_CLIENT_PYTHON_DEFAULT_PROJECT+OPENSHIFT_CLIENT_PYTHON_DEFAULT_OC_LOGLEVEL/OPENSHIFT_CLIENT_PYTHON_DEFAULT_SKIP_TLS_VERIFY)osgetenvrrrxr|rrrrrr!rMASTER_TIMEOUTr)rB root_contexts rrEThreadLocalContext.__init__^s!yy)RTXY')yy1^`d'e$"$)),XZ^"_!$&II.\^b$c!!yy)RTXY! " *WY] ^')yy1bdh'i$y   0#^ r) rxrrrrrrrr|rN)r?rrrrErrrrrr]s$rr)NNNrO)NN)T). __future__rr=rrrr threadingrresultr rrDEFAULT_SSH_USERNAMEintDEFAULT_SSH_PORTlowerDEFAULT_SSH_AUTO_ADDDEFAULT_LOAD_SYSTEM_HOST_KEYSGLOBAL_SKIP_TLS_VERIFYrrobjectr!rrrrrrrrrrrr*r+rrr1r3rrrZrrrrrrs& 'yy!OQUVyy!OQUVryy!KTRSyy!OQXY__af " *aci j p p rw!#LgV\\^cRYYGLMi)fi)X #+  (#!. $4?S^b2Jg #$ N   $   $ >   H      $$2  r