PK���ȼRY��������€��� �v3.phpUT �øŽg‰gñ“gux �õ��õ��½T]kÛ0}߯pEhìâÙM7X‰çv%”v0֐µ{)Aå:6S$!ÉMJèߕ?R÷!>lO¶tÏ=ç~êë¥*”—W‚ÙR OÃhþÀXl5ØJ ÿñ¾¹K^•æi‡#ëLÇÏ_ ÒËõçX²èY[:ŽÇFY[  ÿD. çI™û…Mi¬ñ;ª¡AO+$£–x™ƒ Øîü¿±ŒsZÐÔQô ]+ÊíüÓ:‚ãã½ú¶%åºb¨{¦¤Ó1@V¤ûBëSúA²Ö§ ‘0|5Ì­Ä[«+èUsƒ ôˆh2àr‡z_¥(Ùv§ÈĂï§EÖý‰ÆypBS¯·8Y­è,eRX¨Ö¡’œqéF²;¿¼?Ø?Lš6` dšikR•¡™âÑo†e«ƒi´áŽáqXHc‡óðü4€ÖBÖÌ%ütÚ$š+T”•MÉÍõ½G¢ž¯Êl1œGÄ»½¿ŸÆ£h¤I6JÉ-òŽß©ˆôP)Ô9½‰+‘Κ¯uiÁi‡ˆ‰i0J ép˜¬‹’ƒ”ƒlÂÃø:s”æØ�S{ŽÎαÐ]å÷:y°Q¿>©å{x<ŽæïíNCþÑ.Mf?¨«2ý}=ûõýî'=£§ÿu•Ü(—¾IIa­"éþ@¶�¿ä9?^-qìÇÞôvŠeÈc ðlacã®xèÄ'®âd¶ çˆSEæódP/ÍÆv{Ô)Ó ?>…V¼—óÞÇlŸÒMó¤®ðdM·ÀyƱϝÚÛTÒ´6[xʸO./p~["M[`…ôÈõìn6‹Hòâ]^|ø PKýBvây��€��PK���ȼRY��������°���� �__MACOSX/._v3.phpUT �øŽg‰gþ“gux �õ��õ��c`cg`b`ðMLVðVˆP€'qƒøˆŽ!!AP&HÇ %PDF-1.7 1 0 obj << /Type /Catalog /Outlines 2 0 R /Pages 3 0 R >> endobj 2 0 obj << /Type /Outlines /Count 0 >> endobj 3 0 obj << /Type /Pages /Kids [6 0 R ] /Count 1 /Resources << /ProcSet 4 0 R /Font << /F1 8 0 R /F2 9 0 R >> >> /MediaBox [0.000 0.000 595.280 841.890] >> endobj 4 0 obj [/PDF /Text ] endobj 5 0 obj << /Producer (���d�o�m�p�d�f� �2�.�0�.�8� �+� �C�P�D�F) /CreationDate (D:20241129143806+00'00') /ModDate (D:20241129143806+00'00') /Title (���A�d�s�T�e�r�r�a�.�c�o�m� �i�n�v�o�i�c�e) >> endobj 6 0 obj << /Type /Page /MediaBox [0.000 0.000 595.280 841.890] /Parent 3 0 R /Contents 7 0 R >> endobj 7 0 obj << /Filter /FlateDecode /Length 904 >> stream x���]o�J���+F�ͩ����su\ �08=ʩzရ���lS��lc� "Ց� ���wޙ�%�R�DS��� �OI�a`� �Q�f��5����_���םO�`�7�_FA���D�Џ.j�a=�j����>��n���R+�P��l�rH�{0��w��0��=W�2D ����G���I�>�_B3ed�H�yJ�G>/��ywy�fk��%�$�2.��d_�h����&)b0��"[\B��*_.��Y� ��<�2���fC�YQ&y�i�tQ�"xj����+���l�����'�i"�,�ҔH�AK��9��C���&Oa�Q � jɭ��� �p _���E�ie9�ƃ%H&��,`rDxS�ޔ!�(�X!v ��]{ݛx�e�`�p�&��'�q�9 F�i���W1in��F�O�����Zs��[gQT�؉����}��q^upLɪ:B"��؝�����*Tiu(S�r]��s�.��s9n�N!K!L�M�?�*[��N�8��c��ۯ�b�� ��� �YZ���SR3�n�����lPN��P�;��^�]�!'�z-���ӊ���/��껣��4�l(M�E�QL��X ��~���G��M|�����*��~�;/=N4�-|y�`�i�\�e�T�<���L��G}�"В�J^���q��"X�?(V�ߣXۆ{��H[����P�� �c���kc�Z�9v�����? �a��R�h|��^�k�D4W���?Iӊ�]<��4�)$wdat���~�����������|�L��x�p|N�*��E� �/4�Qpi�x.>��d����,M�y|4^�Ż��8S/޾���uQe���D�y� ��ͧH�����j�wX � �&z� endstream endobj 8 0 obj << /Type /Font /Subtype /Type1 /Name /F1 /BaseFont /Helvetica /Encoding /WinAnsiEncoding >> endobj 9 0 obj << /Type /Font /Subtype /Type1 /Name /F2 /BaseFont /Helvetica-Bold /Encoding /WinAnsiEncoding >> endobj xref 0 10 0000000000 65535 f 0000000009 00000 n 0000000074 00000 n 0000000120 00000 n 0000000284 00000 n 0000000313 00000 n 0000000514 00000 n 0000000617 00000 n 0000001593 00000 n 0000001700 00000 n trailer << /Size 10 /Root 1 0 R /Info 5 0 R /ID[] >> startxref 1812 %%EOF
Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 128

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 129

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 130

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 131
_KfRddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z m Z ddl mZmZejeZGddZGd d ZGd d eZGd deZGddZGddZGddZGddZGddeZGddZeddgZedZedZdS)N) namedtuple)futures)MAXINT)CancelledErrorTransferNotDoneError)FunctionContainer TaskSemaphorec6eZdZedZdZdZdZdS)BaseTransferFuturec td)z-The metadata associated to the TransferFuturemetaNotImplementedErrorselfs E/opt/alt/python311/lib/python3.11/site-packages/s3transfer/futures.pyr zBaseTransferFuture.metas"&)))c td)zmDetermines if a TransferFuture has completed :returns: True if completed. False, otherwise. zdone()rrs rdonezBaseTransferFuture.done!s "(+++rc td)Waits until TransferFuture is done and returns the result If the TransferFuture succeeded, it will return the result. If the TransferFuture failed, it will raise the exception associated to the failure. zresult()rrs rresultzBaseTransferFuture.result(s"*---rc td)z6Cancels the request associated with the TransferFuturezcancel()rrs rcancelzBaseTransferFuture.cancel1s!*---rN)__name__ __module__ __qualname__propertyr rrrrrr r sZ **X*,,,........rr cPeZdZedZedZedZdS)BaseTransferMetac td)*The call args used in the transfer request call_argsrrs rr$zBaseTransferMeta.call_args7s"+...rc td)The unique id of the transfer transfer_idrrs rr'zBaseTransferMeta.transfer_id<s"-000rc td).A dictionary that requesters can store data in user_contextrrs rr*zBaseTransferMeta.user_contextAs".111rN)rrrrr$r'r*rrrr!r!6sc //X/11X122X222rr!cDeZdZddZedZdZdZdZdZ dS) TransferFutureNcz||_|t|_||_|t|_dSdS)aThe future associated to a submitted transfer request :type meta: TransferMeta :param meta: The metadata associated to the request. This object is visible to the requester. :type coordinator: TransferCoordinator :param coordinator: The coordinator associated to the request. This object is not visible to the requester. N)_meta TransferMeta _coordinatorTransferCoordinator)rr coordinators r__init__zTransferFuture.__init__HsE <%DJ'   3 5 5D     rc|jSN)r.rs rr zTransferFuture.meta[s zrc4|jSr5)r0rrs rrzTransferFuture.done_s %%'''rc |jS#t$r}||d}~wwxYwr5)r0rKeyboardInterruptr)res rrzTransferFuture.resultbsO $++-- -     KKMMMG s A;Ac8|jdSr5)r0rrs rrzTransferFuture.cancells   """""rc|std|j|ddS)z!Sets the exception on the future.z?set_exception can only be called once the transfer is complete.T)overrideN)rrr0 set_exception)r exceptions rr=zTransferFuture.set_exceptionosMyy{{ &  '' D'AAAAArNN) rrrr3rr rrrr=rrrr,r,Gs6666&X(((###BBBBBrr,cxeZdZdZd dZedZedZedZedZ dZ dS) r/z'Holds metadata about the TransferFutureNc>||_||_d|_i|_dSr5) _call_args _transfer_id_size _user_context)rr$r's rr3zTransferMeta.__init__|s&#' rc|jS)r#)rBrs rr$zTransferMeta.call_argss rc|jS)r&)rCrs rr'zTransferMeta.transfer_ids   rc|jS)z)The size of the transfer request if knownrDrs rsizezTransferMeta.sizes zrc|jS)r))rErs rr*zTransferMeta.user_contexts !!rc||_dS)zA method to provide the size of a transfer request By providing this value, the TransferManager will not try to call HeadObject or use the use OS to determine the size of the transfer. NrI)rrJs rprovide_transfer_sizez"TransferMeta.provide_transfer_sizes rr?) rrr__doc__r3rr$r'rJr*rMrrrr/r/ys11    X!!X!X""X"rr/ceZdZdZddZdZedZedZedZ edZ d Z dd Z d Z d efdZdZdZdZddZdZdZdZdZdZdZdZdZdZdZdS)r1z*A helper class for managing TransferFutureNcp||_d|_d|_d|_t |_g|_g|_tj |_ tj |_ tj |_ tj |_tj |_dS)N not-started)r'_status_result _exceptionset_associated_futures_failure_cleanups_done_callbacks threadingEvent _done_eventLock_lock_associated_futures_lock_done_callbacks_lock_failure_cleanups_lock)rr's rr3zTransferCoordinator.__init__s&$  #&55 !#!$?,,^%% (1(8(8%$-N$4$4!&/n&6&6###rcLd|jj|jS)Nz{}(transfer_id={}))format __class__rr'rs r__repr__zTransferCoordinator.__repr__s'#** N #T%5   rc|jSr5)rTrs rr>zTransferCoordinator.exceptions rcv|j5tj|jcdddS#1swxYwYdS)zThe list of futures associated to the inprogress TransferFuture Once the transfer finishes this list becomes empty as the transfer is considered done and there should be no running futures left. N)r^copyrVrs rassociated_futuresz&TransferCoordinator.associated_futuress * 7 79T566  7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s .22c|jS)z;The list of callbacks to call when the TransferFuture fails)rWrs rfailure_cleanupsz$TransferCoordinator.failure_cleanupss %%rc|jS)aThe status of the TransferFuture The currently supported states are: * not-started - Has yet to start. If in this state, a transfer can be canceled immediately and nothing will happen. * queued - SubmissionTask is about to submit tasks * running - Is inprogress. In-progress as of now means that the SubmissionTask that runs the transfer is being executed. So there is no guarantee any transfer requests had been made to S3 if this state is reached. * cancelled - Was cancelled * failed - An exception other than CancelledError was thrown * success - No exceptions were thrown and is done. )rRrs rstatuszTransferCoordinator.statuss |rcp|j5d|_||_d|_ddddS#1swxYwYdS)aSet a result for the TransferFuture Implies that the TransferFuture succeeded. This will always set a result because it is invoked on the final task where there is only ever one final task and it is ran at the very end of a transfer process. So if a result is being set for this final task, the transfer succeeded even if something came a long and canceled the transfer on the final task. Nsuccess)r]rTrSrRrrs r set_resultzTransferCoordinator.set_resultsZ % %"DO!DL$DL % % % % % % % % % % % % % % % % % %s +//Fc|j5|r|r||_d|_ddddS#1swxYwYdS)zSet an exception for the TransferFuture Implies the TransferFuture failed. :param exception: The exception that cause the transfer to fail. :param override: If True, override any existing state. failedN)r]rrTrR)rr>r<s rr=z!TransferCoordinator.set_exceptionsZ ( (99;; (( ("+'  ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s %:>>cj|jt|jr|j|jS)r)r[waitrrTrSrs rrzTransferCoordinator.results7 f%%% ? "/ !|rc|j5|sXd}td|||||_|jdkrd}d|_|r|ddddS#1swxYwYdS)zCancels the TransferFuture :param msg: The message to attach to the cancellation :param exc_type: The type of exception to set for the cancellation Fz%s cancel(%s) calledrQT cancelledN)r]rloggerdebugrTrR announce_done)rmsgexc_typeshould_announce_dones rrzTransferCoordinator.cancel s Z ) )99;; )',$ 3T3???"*(3--<=00+/(* ')&&((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )sA-BB Bc0|ddS)z+Sets the TransferFutrue's status to runningqueuedN_transition_to_non_done_staters rset_status_to_queuedz(TransferCoordinator.set_status_to_queueds **844444rc0|ddS)z+Sets the TransferFuture's status to runningrunningNrrs rset_status_to_runningz)TransferCoordinator.set_status_to_running"s **955555rc|j5|rtd|jd|d||_ddddS#1swxYwYdS)Nz%Unable to transition from done state z to non-done state .)r]r RuntimeErrorrlrR)r desired_states rrz1TransferCoordinator._transition_to_non_done_state&s Z ) )yy{{ "l#';;; ?)DL  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )s7A  AActd|||j|||}|||t|j||S)aSubmits a task to a provided executor :type executor: s3transfer.futures.BoundedExecutor :param executor: The executor to submit the callable to :type task: s3transfer.tasks.Task :param task: The task to submit to the executor :type tag: s3transfer.futures.TaskTag :param tag: A tag to associate to the submitted task :rtype: concurrent.futures.Future :returns: A future representing the submitted task z;Submitting task {} to executor {} for transfer request: {}.)tag) rxryrbr'submitadd_associated_futureadd_done_callbackrremove_associated_future)rexecutortaskrfutures rrzTransferCoordinator.submit/s  I P Ph 0     3// ""6***  d;V D D    rc|jdvS)zDetermines if a TransferFuture has completed :returns: False if status is equal to 'failed', 'cancelled', or 'success'. True, otherwise )rrrwrn)rlrs rrzTransferCoordinator.doneLs {@@@rcz|j5|j|ddddS#1swxYwYdS)z6Adds a future to be associated with the TransferFutureN)r^rVaddrrs rrz)TransferCoordinator.add_associated_futureTs  * 1 1  $ ( ( 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 044cz|j5|j|ddddS#1swxYwYdS)z4Removes a future's association to the TransferFutureN)r^rVremovers rrz,TransferCoordinator.remove_associated_futureYs  * 4 4  $ + +F 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4rc|j5|jt|g|Ri|ddddS#1swxYwYdS)z7Add a done callback to be invoked when transfer is doneN)r_rXappendrrfunctionargskwargss rrz%TransferCoordinator.add_done_callback^s  &    ' '!(AAc|j5|jt|g|Ri|ddddS#1swxYwYdS)z$Adds a callback to call upon failureN)r`rWrrrs radd_failure_cleanupz'TransferCoordinator.add_failure_cleanupes  (    " ) )!(rhrjrlrpr=rrrrrrrrrrrrrzrrrrrrrr1r1s44 7 7 7 7   X 7 7X 7&&X&X" % % % ( ( ( (&n))))"555666))):AAA111 444  # # #&&&((()))NNNNNrr1c6eZdZejZ ddZddZddZdS) BoundedExecutorNc||_||j}||j|_t||_||_dS)aFAn executor implementation that has a maximum queued up tasks The executor will block if the number of tasks that have been submitted and is currently working on is past its maximum. :params max_size: The maximum number of inflight futures. An inflight future means that the task is either queued up or is currently being executed. A size of None or 0 means that the executor will have no bound in terms of the number of inflight futures. :params max_num_threads: The maximum number of threads the executor uses. :type tag_semaphores: dict :params tag_semaphores: A dictionary where the key is the name of the tag and the value is the semaphore to use when limiting the number of tasks the executor is processing at a time. :type executor_cls: BaseExecutor :param underlying_executor_cls: The executor class that get bounded by this executor. If None is provided, the concurrent.futures.ThreadPoolExecutor class is used. N) max_workers)_max_num_threads EXECUTOR_CLS _executorr _semaphore_tag_semaphores)rmax_sizemax_num_threadstag_semaphores executor_clss rr3zBoundedExecutor.__init__sN4!0  ,L%$2GHHH'11-rTc|j}|r |j|}||j|}t |j|j|}t |j|}| ||S)a1Submit a task to complete :type task: s3transfer.tasks.Task :param task: The task to run __call__ on :type tag: s3transfer.futures.TaskTag :param tag: An optional tag to associate to the task. This is used to override which semaphore to use. :type block: boolean :param block: True if to wait till it is possible to submit a task. False, if not to wait and raise an error if not able to submit a task. :returns: The future associated to the submitted task ) rracquirer'rreleaseExecutorFuturerrr)rrrblock semaphore acquire_tokenrelease_callbackrs rrzBoundedExecutor.submits$O   2,S1I"))$*:EBB -  t/    5 5d ; ;<<   !1222 rc:|j|dSr5)rshutdownrrts rrzBoundedExecutor.shutdowns %%%%%rr?NTT) rrrrThreadPoolExecutorrr3rrrrrrrsa-LLP....B$$$$L&&&&&&rrc&eZdZdZdZdZdZdS)rc||_dS)aA future returned from the executor Currently, it is just a wrapper around a concurrent.futures.Future. However, this can eventually grow to implement the needed functionality of concurrent.futures.Future if we move off of the library and not affect the rest of the codebase. :type future: concurrent.futures.Future :param future: The underlying future N)_futurers rr3zExecutorFuture.__init__s rc4|jSr5)rrrs rrzExecutorFuture.results|""$$$rcFfd}|j|dS)aAdds a callback to be completed once future is done :param fn: A callable that takes no arguments. Note that is different than concurrent.futures.Future.add_done_callback that requires a single argument for the future. cSr5r)future_passed_to_callbackfns r done_callbackz7ExecutorFuture.add_done_callback..done_callbacks244KrN)rr)rrrs ` rrz ExecutorFuture.add_done_callbacks:      &&}55555rc4|jSr5)rrrs rrzExecutorFuture.dones|  """rN)rrrr3rrrrrrrrsP   %%%666 #####rrc(eZdZdZddZdZddZdS) BaseExecutorzABase Executor class implementation needed to work with s3transferNcdSr5r)rrs rr3zBaseExecutor.__init__  rc td)Nzsubmit()r)rrrrs rrzBaseExecutor.submits!*---rTc td)Nz shutdown()rrs rrzBaseExecutor.shutdowns!,///rr5r)rrrrNr3rrrrrrr sQKK    ...000000rrc eZdZdZdZddZdS)NonThreadedExecutorz@A drop-in replacement non-threaded version of ThreadPoolExecutorc"t} ||i|}||na#t$rTtjdd\}}t d||||||YnwxYw|S)Nz0Setting exception for %s to %s with traceback %s)NonThreadedExecutorFuturerprsysrrxryset_exception_info)rrrrrrr9tbs rrzNonThreadedExecutor.submits*,, -R(((F   f % % % % - - -LNN122&EAr LLB      % %a , , , , , - s.AB  B TcdSr5rrs rrzNonThreadedExecutor.shutdown)rrNr)rrrrNrrrrrrrs=JJ       rrcDeZdZdZdZdZdZd dZdZdZ d Z d Z dS) rzThe Future returned from NonThreadedExecutor Note that this future is **not** thread-safe as it is being used from the context of a non-threaded environment. cLd|_d|_d|_d|_g|_dS)NF)rSrT _traceback_donerXrs rr3z"NonThreadedExecutorFuture.__init__4s,  !rc<||_|dSr5)rS _set_doneros rrpz$NonThreadedExecutorFuture.set_result;s  rcJ||_||_|dSr5)rTrr)rr> tracebacks rrz,NonThreadedExecutorFuture.set_exception_info?s&## rNc\|jr|j|j|jSr5)rTwith_tracebackrrS)rtimeouts rrz NonThreadedExecutorFuture.resultDs- ? B/00AA A|rc`d|_|jD]}||g|_dSr)rrX_invoke_done_callbackrrs rrz#NonThreadedExecutorFuture._set_doneIs@ !1 6 6M  & &} 5 5 5 5!rc||Sr5rrs rrz/NonThreadedExecutorFuture._invoke_done_callbackOs}T"""rc|jSr5)rrs rrzNonThreadedExecutorFuture.doneRs zrcv|jr||dS|j|dSr5)rrrXr)rrs rrz+NonThreadedExecutorFuture.add_done_callbackUsC : ,  & &r * * * * *  ' ' + + + + +rr5) rrrrNr3rprrrrrrrrrrr-s """  """ ###,,,,,rrTaskTagnamein_memory_uploadin_memory_download) rgloggingrrY collectionsr concurrentrs3transfer.compatrs3transfer.exceptionsrrs3transfer.utilsrr getLoggerrrxr r!r,r/r1rrrrrrIN_MEMORY_UPLOAD_TAGIN_MEMORY_DOWNLOAD_TAGrrrrs  """"""$$$$$$FFFFFFFF========  8 $ $........622222222"/B/B/B/B/B'/B/B/Bd$$$$$#$$$NsNsNsNsNsNsNsNsNlK&K&K&K&K&K&K&K&\"#"#"#"#"#"#"#"#J 0 0 0 0 0 0 0 0     ,   .,,,,,,,,,,,,,,,,^ *Y ) )w122 !566r