Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
to_process.cpython-313.pyc88 linesDownload Raw Back to __pycache__
1�

2�jF&����%SSKJr SrSSKrSSKrSSKrSSKrSSKJr SSK	J3r4 SSKJrJ
r
 SSKJrJr SS	KJrJrJr SS5KJr SSKJr SSKJr SS
KJrJr SSKJrJ r J!r! SSK"J#r#J$r$ SSK%J&r& \RNS:�a	SSKJ(r(J)r) OSSK*J(r(J)r) Sr+\"S5r,\("S5r-\#"S5r.S\/S'\#"S5r0S\/S'\#"S5r1S\/S'SSS.S"Sjjr2S#Sjr3S$S jr4\5S!:Xa\4"5 gg)%�)�annotations)�current_default_process_limiter�process_worker�run_syncN)�deque)�Callable)�module_from_spec�spec_from_file_location)�TypeVar�cast�)�current_time�get_async_backend�get_cancelled_exc_class)�BrokenWorkerProcess)�open_process)�CapacityLimiter)�CancelScope�6fail_after)�ByteReceiveStream�ByteSendStream�Process)�RunVar�checkpoint_if_cancelled)�BufferedByteReceiveStream)��)�TypeVarTuple�Unpacki,�T_Retval�PosArgsT�_process_pool_workerszRunVar[set[Process]]�_process_pool_idle_workersz$RunVar[deque[tuple[Process, float]]]�_default_process_limiterzRunVar[CapacityLimiter]F)�cancellable�limiterc	��H	^^^^# �SUUUU4Sjjn[5IShv�N [R"SX4[RS9n[R5m[R5nU=(d7 [5IShv�N U(Ga UR5umnTRc�[[ TR"5m[%[[&TR(55m[+5n/n	U(a`X�SS-8[,:aOMUR/5up�U9R15 TR3U105 U	R5U115 U(aM`[7SS9 U	HnUR95IShv�N M SSS5 GOUTR3T5 U(aGM [:R<S	S12[>/n[AU[BRD[BRDS9IShv�Nm[[ TR"5m[%[[&TR(55m[GS5 TRIS
5IShv�Nn
SSS5 W
S:wa[KSU
<35e[M[:RNSSS5n[R"S[:RPU4[RS9nU"U5IShv�N TRWT5 [7U(+S9 [[XU"U5IShv�N5TT;aUR5T[+545 sSSS5 sSSS5IShv�N $GN:![a[ [5m[5n[RT5 [RU5 [5RT5 GNNf=fGN;GN?!,(df   GN@=fGN�GN�!,(df   GN�=fGN![J[S54a e[Ta!nTR15 [KS5UeSnAff=fGN$N�!TT;aUR5T[+545 ff=f!,(df   O=fSSS5IShv�N g!,IShv�N(df   g=f7f)a�13Call the given function with the given arguments in a worker process.14 15If the ``cancellable`` option is enabled and the task waiting for its completion is16cancelled, the worker process running it will be abruptly terminated using SIGKILL17(or ``terminateProcess()`` on Windows).18 19:param func: a callable20:param args: positional arguments for the callable21:param cancellable: ``True`` to allow cancellation of the operation while it's22    running23:param limiter: capacity limiter to use to limit the total amount of processes24    running (if omitted, the default limiter is used)25:raises NoEventLoopError: if no supported asynchronous event loop is running in the26    current thread27:return: an awaitable that yields the return value of the function.28 29c���># �T	RU5IShv�N TRSS5IShv�NnURS5up#US;a[SU<35eTR	[U55IShv�Nn[R "U5nUS:Xa[U[5(deUeU$N�N�N?![a�nT30RT5 TR5 [SS9 TR5IShv�N SSS5 O!!,(df   O=f![a Of=f[U[55(ae[UeSnAff=f7f)	N�31�2� )�RETURN�	EXCEPTION�-Worker process returned unexpected response: T��shieldr-)�send�
receive_until�split�RuntimeError�receive_exactly�int�
BaseException�discard�killr�aclose�ProcessLookupError�32isinstancerr�pickle�loads)�pickled_cmd�response�status�length�pickled_response�exc�retval�buffered�process�stdin�workerss       �����VD:\code\apps\devtools\python\user_packages\Python313\site-packages\anyio/to_process.py�send_raw_command�"run_sync.<locals>.send_raw_commandEs<����	3��*�*�[�)�)�)�%�3�3�E�2�>�>�H�%�^�^�D�1�N�F��6�6�"�C�H�<�P���&.�%=�%=�c�&�k�%J�J�����.�/���\�!��f�m�4�4�4�4��L��M�9
*�>� K���	3��O�O�G�$�
����� ��-�!�.�.�*�*�*�.�-�-��%�
��
���#�6�8�9�9��)�s�2��	3�s��E!�B?�B9�B?�B;�A	B?�=B=�>B?�7E!�9B?�;B?�=B?�?33E�	E�D(�4D�D�	D�D(�E�34D%	�!D(�$E�%D(�(35D5�2E�4D5�5$E�E�E!N�run)�protocolrr
Tr/z-uz-m)rH�stdout���READY36r.�__main__�__file__�initz*Error during worker process initialization)r?�bytes�return�object)-rr=�dumps�HIGHEST_PROTOCOLr"�getr#�LookupError�setrr�#setup_process_pool_exit_at_shutdownr�pop�37returncoderrrHrrrOr�WORKER_MAX_IDLE_TIME�popleftr9�remove�appendrr:�sys�38executable�__name__r�39subprocess�PIPEr�receiver�getattr�modules�pathrr7�addr )�funcr%r&�argsrK�request�idle_workers�40idle_since�now�killed_processes�process_to_kill�killed_process�command�message�main_module_path�pickledrDrFrGrHrIs                 @@@@rJrr,s�����2��B"�41#�#�#��l�l�E�4�.��9P�9P�Q�G�I�'�+�+�-��1�5�5�7���;�9�;�;�;��".�"2�"2�"4��G�Z��!�!�)��^�W�]�]�;��4��*�G�N�N�;���#�n��24� �"��!�_�Q�/�/�2F�F��2>�2F�2F�2H�/�O�#�(�(�*��N�N�?�3�$�+�+�O�<�#�l�!��-�*:��,�3�3�5�5�5�+;�.���N�N�7�#�7�l�:�~�~�t�T�8�<�G�(��z���z�����G�
��^�W�]�]�;��4��*�G�N�N�;��� ��^�$,�$4�$4�Q�$7�7�G�$��j�(�-�G��{�S���$+�3�;�;�z�+B�J�PT�#U� � �,�,��S�X�X�'7�8�#�4�4���'�w�/�/�/�
�K�K�� �
�K��
0�
C��H�,<�W�,E�&E�F��g�%� �'�'��,�.�(A�B�1�
0�E<�;�;�$���I��%���w���!�!�'�*�"�&�&�|�4���?�?��H�I��<�66�.�-���8�$�^��0��'�)@�)B�C�
�� �
�����)�@�����
��'F�I<��L�g�%� �'�'��,�.�(A�B�&��	1�
0��E<�;�;�;�;�;�sj�R"�M�)R"�42(M�2R"�	O�43R"�
CR�&	R�/O44�O45�	O46�"R�6AR�8O�9R�>AO7�O"�O�O"� A:O7�O4�O7�R�>Q%�P>�P9�P>�!Q%�>	R�R"�P<�R"�A!O�=R"�O�R"�O47�48 49O	�	R�O"�"50O1	�,	O7�7P6�P1�1P6�6R�9P>�<R"�>$Q"�"Q%�%51Q3	�/R�6R"�R�R"�R�R�R�R"c���[R5$![aA [[R52"5=(d S5n[R
U5 Us$f=f)z�53Return the capacity limiter that is used by default to limit the number of worker54processes.55 56:return: a capacity limiter object57 58�)r$r[r\r�os�	cpu_countr])r&s rJrr�sM���'�+�+�-�-����!�"�,�,�.�"5�A�6�� �$�$�W�-����s��AA!� A!c�^�[Rn[Rn[[R595[l[[R60S5[lURRS5 S=p#[R"UR5tpEUS:XaUupeU"U6nO�US:Xa�Uu[ln[RS	U(a�[RRU5(a^[SU5n	U	(aJU	R(a9[!U	5n61U	RR#U625 U63[RS'Ub(Sn[R&"U[R(5nO(Sn[R&"U[R(5nURRS	U[+U54-5 URRU5 [-U[.5(aUeGM�![anUnSnAN�SnAff=f![anUnSnAN�SnAff=f![$a g[a
nUnSnAGNSnAff=f![a3nUnSn[R&"U[R(5nSnAN�SnAff=f)64N�wrRrMrUrS�__mp_main__r-r,s%s %d65)rerHrO�openr~�devnull�buffer�writer=�loadr7rmrl�isfiler66�loaderr	�exec_module�EOFErrorrYrZ�lenr<�67SystemExit)
rHrOrE�	exceptionrxrprorDrz�spec�mainrAr{s
             rJrr�s��
�I�I�E�
�Z�Z�F��R�Z�Z� �C�I��b�j�j�#�&�C�J�68�M�M���69�#�70�!�!��	(�#�[�[����6�N�G��%��!�71��$�!�4�[�F��F�"�-1�*���*��K�K�72�+�#������7G�(H�(H�(�6�}�FV�W���D�K�K�#3�D�#9�D� �K�K�3�3�D�9�6:�C�K�K�73�3�74	A��$�%�� �,�,�y�&�2I�2I�J��"�� �,�,�v�v�/F�/F�G��	�
�
���J�&�#�g�,�)?�?�@��
�
���G�$��i��,�,��O�_��%�$� #�I��$��)�(�$'�	��(��1�	���	��I��	��>�	A��I�!�F��l�l�3��(?�(?�@�G��	A�sm�!I75�2H�	AH1�'*I/�'I/�76H.�"H)�)H.�177I�;I�I�78 79I,�	I,�I'�'I,�/80J,�9)J'�'J,rS)81roz&Callable[[Unpack[PosArgsT]], T_Retval]rpzUnpack[PosArgsT]r%�boolr&zCapacityLimiter | NonerWr )rWr)rW�None)6�82__future__r�__all__r~r=rhre�collectionsr�collections.abcr�importlib.utilr	r83�typingrr�_core._eventlooprrr�_core._exceptionsr�_core._subprocessesr�_core._synchronizationr�_core._tasksrr�abcrrr�lowlevelrr�streams.bufferedr�version_inforr�typing_extensionsrar r!r"�__annotations__r#r$rrrrg��rJ�<module>r�s��"���84�
��85��$�D� �V�V�2�-�3�1�;�;�5�7����w��+�+�6����:����86�#��.4�5L�.M��+�M�CI� �D��@��5;�;U�4V��1�V��&*�	OC�870�OC��OC��OC�$�	OC�88�OC�d
� 8�v�z����r�
codekingpro/portable-devtools · Team Ai