Ë „Ÿõfò&ãó —dZddlZddlmZmZmZddlmZmZm Z m Z m Z ddl m Z mZmZddlmZGd„d eee««ZGd „d eee¬ «Zy) zKernel Provisioner ClasseséN)ÚABCÚABCMetaÚabstractmethod)ÚAnyÚDictÚListÚOptionalÚUnion)ÚInstanceÚLoggingConfigurableÚUnicodeé)ÚKernelConnectionInfocó —eZdZy)ÚKernelProvisionerMetaN)Ú__name__Ú __module__Ú __qualname__©óúg/var/www/cvtools/html/venv/lib/python3.12/site-packages/jupyter_client/provisioning/provisioner_base.pyrr s„Ørrcó—eZdZUdZedd¬«Zeed<edd¬«Z e e efed<iZ e ed<eed efd „««Zed eefd „«Zed eefd „«Zed ed dfd„«Zed#ded dfd„«Zed#ded dfd„«Zedee ded e fd„«Zed#ded dfd„«Zd#ded dfd„Zded ee effd„Zded dfd„Zd ee effd„Z ded dfd„Z!d$de"d e"fd„Z#d%de"d e"fd„Z$dee e fd dfd „Z%d!ee e fd ee e ffd"„Z&y)&ÚKernelProvisionerBaseaã Abstract base class defining methods for KernelProvisioner classes. A majority of methods are abstract (requiring implementations via a subclass) while some are optional and others provide implementations common to all instances. Subclasses should be aware of which methods require a call to the superclass. Many of these methods model those of :class:`subprocess.Popen` for parity with previous versions where the kernel process was managed directly. z$jupyter_client.kernelspec.KernelSpecT)Ú allow_noneÚ kernel_specNÚ kernel_idÚconnection_infoÚreturncó—y)zÙ Returns true if this provisioner is currently managing a process. This property is asserted to be True immediately following a call to the provisioner's :meth:`launch_kernel` method. Nr©Úselfs rÚ has_processz!KernelProvisionerBase.has_process$s€ð rcƒó K—y­w)zä Checks if kernel process is still running. If running, None is returned, otherwise the process's integer-valued exit code is returned. This method is called from :meth:`KernelManager.is_alive`. Nrr s rÚpollzKernelProvisionerBase.poll/ó èø€ð ùó‚cƒó K—y­w)zó Waits for kernel process to terminate. This method is called from `KernelManager.finish_shutdown()` and `KernelManager.kill_kernel()` when terminating a kernel gracefully or immediately, respectively. Nrr s rÚwaitzKernelProvisionerBase.wait9s èø€ð ùr&Úsignumcƒó K—y­w)z» Sends signal identified by signum to the kernel process. This method is called from `KernelManager.signal_kernel()` to send the kernel process a signal. Nr)r!r)s rÚ send_signalz!KernelProvisionerBase.send_signalDr%r&Úrestartcƒó K—y­w)aL Kill the kernel process. This is typically accomplished via a SIGKILL signal, which cannot be caught. This method is called from `KernelManager.kill_kernel()` when terminating a kernel immediately. restart is True if this operation will precede a subsequent launch_kernel request. Nr©r!r,s rÚkillzKernelProvisionerBase.killNs èø€ð ùr&cƒó K—y­w)a© Terminates the kernel process. This is typically accomplished via a SIGTERM signal, which can be caught, allowing the kernel provisioner to perform possible cleanup of resources. This method is called indirectly from `KernelManager.finish_shutdown()` during a kernel's graceful termination. restart is True if this operation precedes a start launch_kernel request. Nrr.s rÚ terminatezKernelProvisionerBase.terminate[s èø€ð ùr&ÚcmdÚkwargsc‹ó K—y­w)zÑ Launch the kernel process and return its connection information. This method is called from `KernelManager.launch_kernel()` during the kernel manager's start kernel sequence. Nr)r!r2r3s rÚ launch_kernelz#KernelProvisionerBase.launch_kernelir%r&cƒó K—y­w)a" Cleanup any resources allocated on behalf of the kernel provisioner. This method is called from `KernelManager.cleanup_resources()` as part of its shutdown kernel sequence. restart is True if this operation precedes a start launch_kernel request. Nrr.s rÚcleanupzKernelProvisionerBase.cleanupsó èø€ð ùr&cƒó K—y­w)a‚ Allows the provisioner to determine if the kernel's shutdown has been requested. This method is called from `KernelManager.request_shutdown()` as part of its shutdown sequence. This method is optional and is primarily used in scenarios where the provisioner may need to perform other operations in preparation for a kernel's shutdown. Nrr.s rÚshutdown_requestedz(KernelProvisionerBase.shutdown_requestedr8r&c‹óÖK—|jdtj«j«}|j |j |««|j |«||d<|S­w)a( Perform any steps in preparation for kernel process launch. This includes applying additional substitutions to the kernel launch command and environment. It also includes preparation of launch parameters. NOTE: Subclass implementations are advised to call this method as it applies environment variable substitutions from the local environment and calls the provisioner's :meth:`_finalize_env()` method to allow each provisioner the ability to cleanup the environment variables that will be used by the kernel. This method is called from `KernelManager.pre_start_kernel()` as part of its start kernel sequence. Returns the (potentially updated) keyword arguments that are passed to :meth:`launch_kernel()`. Úenv)ÚpopÚosÚenvironÚcopyÚupdateÚ/_KernelProvisionerBase__apply_env_substitutionsÚ _finalize_env)r!r3r<s rÚ pre_launchz KernelProvisionerBase.pre_launch‹sXèø€ð$j‰j˜¤§ ¡ Ó+×0Ñ0Ó2ˆØ ‰ 4×1Ñ1°#Ó6Ô7Ø ×ј3Ô؈ˆu‰ àˆ ùs‚A'A)c‹ó K—y­w)z¾ Perform any steps following the kernel process launch. This method is called from `KernelManager.post_start_kernel()` as part of its start kernel sequence. Nr)r!r3s rÚ post_launchz!KernelProvisionerBase.post_launch¤s èø€ð ùr&cƒóNK—i}|j|d<|j|d<|S­w)aÞ Captures the base information necessary for persistence relative to this instance. This enables applications that subclass `KernelManager` to persist a kernel provisioner's relevant information to accomplish functionality like disaster recovery or high availability by calling this method via the kernel manager's `provisioner` attribute. NOTE: The superclass method must always be called first to ensure proper serialization. rr©rr©r!Úprovisioner_infos rÚget_provisioner_infoz*KernelProvisionerBase.get_provisioner_info­s5èø€ð,.ÐØ(,¯©Ð˜Ñ%Ø.2×.BÑ.BÐÐ*Ñ+ØÐùs‚#%rJcƒó4K—|d|_|d|_y­w)aç Loads the base information necessary for persistence relative to this instance. The inverse of `get_provisioner_info()`, this enables applications that subclass `KernelManager` to re-establish communication with a provisioner that is managing a (presumably) remote kernel from an entirely different process that the original provisioner. NOTE: The superclass method must always be called first to ensure proper deserialization. rrNrHrIs rÚload_provisioner_infoz+KernelProvisionerBase.load_provisioner_info¼s"èø€ð*¨+Ñ6ˆŒØ/Ð0AÑBˆÕùs‚Ú recommendedcó—|S)aE Returns the time allowed for a complete shutdown. This may vary by provisioner. This method is called from `KernelManager.finish_shutdown()` during the graceful phase of its kernel shutdown sequence. The recommended value will typically be what is configured in the kernel manager. r©r!rNs rÚget_shutdown_wait_timez,KernelProvisionerBase.get_shutdown_wait_timeÊs €ðÐrcó—|S)zÚ Returns the expected upper bound for a kernel (re-)start to complete. This may vary by provisioner. The recommended value will typically be what is configured in the kernel restarter. rrPs rÚget_stable_start_timez+KernelProvisionerBase.get_stable_start_timeÕs €ðÐrr<có¾—|jjrG|jjj«jd«r|j dd«yyy)zþ Ensures env is appropriate prior to launch. This method is called from `KernelProvisionerBase.pre_launch()` during the kernel's start sequence. NOTE: Subclasses should be sure to call super()._finalize_env(env) ÚpythonÚPYTHONEXECUTABLEN)rÚlanguageÚlowerÚ startswithr=)r!r<s rrCz#KernelProvisionerBase._finalize_envÞsP€ð × Ñ × $Ò $¨×)9Ñ)9×)BÑ)B×)HÑ)HÓ)J×)UÑ)UÐV^Ô)_ð G‰GÐ&¨Õ -ð*`Ð $rÚsubstitution_valuescóÚ—i}|jr\ddlm}|jj}|j «D]-\}}|j |||«j |«i«Œ/|S)aq Walks entries in the kernelspec's env stanza and applies substitutions from current env. This method is called from `KernelProvisionerBase.pre_launch()` during the kernel's start sequence. Returns the substituted list of env entries. NOTE: This method is private and is not intended to be overridden by provisioners. r)ÚTemplate)rÚstringr\r<ÚitemsrAÚsafe_substitute)r!rZÚsubstituted_envr\Ú templated_envÚkÚvs rÚ__apply_env_substitutionsz/KernelProvisionerBase.__apply_env_substitutionsìso€ðˆØ × Ò Ý 'ð !×,Ñ,×0Ñ0ˆMØ%×+Ñ+Ó-ò ^‘1Ø×&Ñ&¨©8°A«;×+FÑ+FÐGZÓ+[Ð'\Õ]ð ^àÐr)F)g@)g$@)'rrrÚ__doc__r rrÚ__annotations__r rr ÚstrrrÚpropertyrÚboolr"r Úintr$r(r+r/r1rr5r7r:rrDrFrKrMÚfloatrQrSrCrBrrrrrs*…ñ ñ Ð FÐSWÔX€KÓXÙ%,¨T¸dÔ%C€IˆuS˜'\Ñ"ÓCØ,.€OÐ)Ó.à Øð ˜Tò óóð ðð ˜H S™Mò óð ðð ˜H S™Mò óð ðð ¨ð °ò óð ðñ   $ð  °4ò  óð  ðñ   tð  ¸ò  óð  ðð  t¨C¡yð ¸Cð ÐDXò óð ðñ   Tð  °dò  óð  ñ  °ð  Àó  ð¨ð°°c¸3°h±óð2 ¨#ð °$ó ð  ¨D°°c°©Nó  ð C¸Dð CÀTó Cñ °%ð À%ó ñ°ðÀ%óð .  c¨3 h¡ð .°Dó .ð¸TÀ#ÀsÀ(¹^ðÐPTÐUXÐZ]ÐU]ÑP^ôrr)Ú metaclass)rer>ÚabcrrrÚtypingrrrr r Útraitlets.configr r r ÚconnectrÚtyperrrrrúrrsKðÙ ó ß,Ñ,ß3Õ3çCÑCå*ô ˜G¡TÐ*=Ó%>ô ôpØÐ Ð(=öpr