§ ÁÞMhò&ãó´—dZddlZddlmZmZmZddlmZmZm Z m Z m Z ddl m Z mZmZddlmZGd„d eee¦«¦«ZGd „d eee¬ ¦«ZdS) zKernel Provisioner ClasseséN)ÚABCÚABCMetaÚabstractmethod)ÚAnyÚDictÚListÚOptionalÚUnion)ÚInstanceÚLoggingConfigurableÚUnicodeé)ÚKernelConnectionInfocó—eZdZdS)ÚKernelProvisionerMetaN)Ú__name__Ú __module__Ú __qualname__©óúl/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/jupyter_client/provisioning/provisioner_base.pyrr s€€€€€Ø€DrrcóŽ—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$d"ee e fd dfd#„Z%d$ee e fd ee e ffd%„Z&dS))Ú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ó—dS)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—dS)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/ó èè€ð ˆrcƒó K—dS)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—dS)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%rFÚrestartcƒó K—dS)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 èè€ð ˆrcƒó K—dS)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—dS)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!r1r2s rÚ launch_kernelz#KernelProvisionerBase.launch_kernelir%rcƒó K—dS)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ó èè€ð ˆrcƒó K—dS)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_requestedr7rc‹óòK—| dtj¦« ¦«}| | |¦«¦«| |¦«||d<|S)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!r2r;s rÚ pre_launchz KernelProvisionerBase.pre_launch‹skèè€ð$jŠj˜¥¤ Ñ+Ô+×0Ò0Ñ2Ô2ˆØ Š 4×1Ò1°#Ñ6Ô6Ñ7Ô7Ð7Ø ×Ò˜3ÑÔÐ؈ˆu‰ àˆ rc‹ó K—dS)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!r2s rÚ post_launchz!KernelProvisionerBase.post_launch¤s èè€ð ˆrcƒó6K—i}|j|d<|j|d<|S)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­s0èè€ð,.ÐØ(,¬Ð˜Ñ%Ø.2Ô.BÐÐ*Ñ+ØÐrrIcƒó>K—|d|_|d|_dS)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. rrNrGrHs rÚload_provisioner_infoz+KernelProvisionerBase.load_provisioner_info¼s(èè€ð*¨+Ô6ˆŒØ/Ð0AÔBˆÔÐÐrç@Ú 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 €ðÐrç$@có—|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ó´—|jjrI|jj ¦« d¦«r| dd¦«dSdSdS)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 rrBz#KernelProvisionerBase._finalize_envÞsk€ð Ô Ô $ð .¨Ô)9Ô)B×)HÒ)HÑ)JÔ)J×)UÒ)UÐV^Ñ)_Ô)_ð .ð GŠGÐ&¨Ñ -Ô -Ð -Ð -Ð -ð .ð .ð .ð .rÚsubstitution_valuescóÖ—i}|jr_ddlm}|jj}| ¦«D]8\}}| |||¦« |¦«i¦«Œ9|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;Úitemsr@Úsafe_substitute)r!r[Úsubstituted_envr]Ú templated_envÚkÚvs rÚ__apply_env_substitutionsz/KernelProvisionerBase.__apply_env_substitutionsìsŽ€ðˆØ Ô ð ^Ø 'Ð 'Ð 'Ð 'Ð 'Ð 'ð !Ô,Ô0ˆMØ%×+Ò+Ñ-Ô-ð ^ð ^‘1Ø×&Ò&¨¨8¨8°A©;¬;×+FÒ+FÐGZÑ+[Ô+[Ð'\Ñ]Ô]Ð]Ð]ØÐr)F)rM)rR)'rrrÚ__doc__r rrÚ__annotations__r rr ÚstrrrÚpropertyrÚboolr"r Úintr$r'r*r.r0rr4r6r9rrCrErJrLÚfloatrQrTrBrArrrrrso€€€€€€ð ð ð xÐ FÐSWÐXÑXÔX€KÐXÐXÑXØ%, W¨T¸dÐ%CÑ%CÔ%C€IˆuS˜'\Ô"ÐCÐCÑCØ,.€OÐ)Ð.Ð.Ñ.à Øð ˜Tð ð ð ñ„^ñ„Xð ðð ˜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ð Cð Cð ð °%ð À%ð ð ð ð ðð°ðÀ%ððððð .  c¨3 h¤ð .°Dð .ð .ð .ð .ð¸TÀ#ÀsÀ(¼^ðÐPTÐUXÐZ]ÐU]ÔP^ððððððrr)Ú metaclass)rfr=ÚabcrrrÚtypingrrrr r Útraitlets.configr r r ÚconnectrÚtyperrrrrúrssðØ Ð ð € € € Ø,Ð,Ð,Ð,Ð,Ð,Ð,Ð,Ð,Ð,Ø3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3àCÐCÐCÐCÐCÐCÐCÐCÐCÐCà*Ð*Ð*Ð*Ð*Ð*ð ð ð ð ð ˜G T TÐ*=Ñ%>Ô%>ñ ô ð ðpðpðpðpðpØÐ Ð(=ðpñpôpðpðpðpr