U ¬9%eÖã@sHGdd„dƒZGdd„deƒZGdd„deƒZGdd„deƒZeƒZdS) c@sleZdZdZddd„Zdd„Zdd „Zdd d „Zdd d„Zdd„Z dd„Z dd„Z dd„Z e ddd„ƒZdS)ÚCallbacka¨ Base class and interface for callback mechanism This class can be used directly for monitoring file transfers by providing ``callback=Callback(hooks=...)`` (see the ``hooks`` argument, below), or subclassed for more specialised behaviour. Parameters ---------- size: int (optional) Nominal quantity for the value that corresponds to a complete transfer, e.g., total number of tiles or total number of bytes value: int (0) Starting internal counter value hooks: dict or None A dict of named functions to be called on each update. The signature of these must be ``f(size, value, **kwargs)`` NécKs ||_||_|pi|_||_dS©N)ÚsizeÚvalueÚhooksÚkw)ÚselfrrrÚkwargs©r úO/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/fsspec/callbacks.pyÚ__init__s zCallback.__init__cCs||_| ¡dS)zß Set the internal maximum size attribute Usually called if not initially set at instantiation. Note that this triggers a ``call()``. Parameters ---------- size: int N)rÚcall©rrr r r Úset_sizes zCallback.set_sizecCs||_| ¡dS)z… Set the internal value state Triggers ``call()`` Parameters ---------- value: int N©rr )rrr r r Úabsolute_update*s zCallback.absolute_updateécCs|j|7_| ¡dS)z‹ Delta increment the internal counter Triggers ``call()`` Parameters ---------- inc: int Nr©rÚincr r r Úrelative_update7s zCallback.relative_updatecKsr|js dS|j ¡}| |¡|rH||jkr0dS|j||j|jf|ŽS|j ¡pTgD]}||j|jf|ŽqVdS)a Execute hook(s) with current state Each function is passed the internal size and current value Parameters ---------- hook_name: str or None If given, execute on this hook kwargs: passed on to (all) hook(s) N)rrÚcopyÚupdaterrÚvalues)rÚ hook_namer rÚhookr r r r Ds    z Callback.callccs|D]}| ¡|VqdS)z Wrap an iterable to call ``relative_update`` on each iterations Parameters ---------- iterable: Iterable The iterable that is being wrapped N)r)rÚiterableÚitemr r r Úwrap[s z Callback.wrapcCsdS)a; Set callbacks for child transfers If this callback is operating at a higher level, e.g., put, which may trigger transfers that can also be monitored. The passed kwargs are to be *mutated* to add ``callback=``, if this class supports branching to children. Parameters ---------- path_1: str Child's source path path_2: str Child's destination path kwargs: dict arguments passed to child method, e.g., put_file. Returns ------- Nr ©rZpath_1Zpath_2r r r r ÚbranchhszCallback.branchcOsdSrr )rÚ_Ú__r r r Úno_op€szCallback.no_opcCs|jS)zP If undefined methods are called on this class, nothing happens )r")rrr r r Ú __getattr__ƒszCallback.__getattr__cCs|dkr tS|S)aTransform callback=... into Callback instance For the special value of ``None``, return the global instance of ``NoOpCallback``. This is an alternative to including ``callback=_DEFAULT_CALLBACK`` directly in a method signature. N)Ú_DEFAULT_CALLBACK)ÚclsZmaybe_callbackr r r Ú as_callback‰szCallback.as_callback)NrN)r)N)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__r rrrr rrr"r#Ú classmethodr&r r r r rs   rc@seZdZdZdd„ZdS)Ú NoOpCallbackz> This implementation of Callback does exactly nothing cOsdSrr )rÚargsr r r r r ›szNoOpCallback.callN)r'r(r)r*r r r r r r,–sr,cs2eZdZdZd ‡fdd„ Zdd„Zdd„Z‡ZS) ÚDotPrinterCallbackzÄ Simple example Callback implementation Almost identical to Callback with a hook that prints a char; here we demonstrate how the outer layer may print "#" and the inner layer "." ú#c s||_tƒjf|ŽdSr)ÚchrÚsuperr )rZ chr_to_printr ©Ú __class__r r r §szDotPrinterCallback.__init__cCstdƒ|d<dS)z;Mutate kwargs to add new instance with different print charÚ.ÚcallbackN)r.rr r r r«szDotPrinterCallback.branchcKst|jdddS)zJust outputs a characterÚ)ÚendN)Úprintr0)rr r r r r ¯szDotPrinterCallback.call)r/)r'r(r)r*r rr Ú __classcell__r r r2r r.Ÿsr.cs<eZdZdZd ‡fdd„ Zdd„Zd dd „Zd d „Z‡ZS)Ú TqdmCallbackae A callback to display a progress bar using tqdm Parameters ---------- tqdm_kwargs : dict, (optional) Any argument accepted by the tqdm constructor. See the `tqdm doc `_. Will be forwarded to tqdm. Examples -------- >>> import fsspec >>> from fsspec.callbacks import TqdmCallback >>> fs = fsspec.filesystem("memory") >>> path2distant_data = "/your-path" >>> fs.upload( ".", path2distant_data, recursive=True, callback=TqdmCallback(), ) You can forward args to tqdm using the ``tqdm_kwargs`` parameter. >>> fs.upload( ".", path2distant_data, recursive=True, callback=TqdmCallback(tqdm_kwargs={"desc": "Your tqdm description"}), ) Nc s\zddl}||_Wn,tk r>}ztdƒ|‚W5d}~XYnX|pFi|_tƒj||ŽdS)Nrz0Using TqdmCallback requires tqdm to be installed)ÚtqdmÚ_tqdmÚ ImportErrorÚ _tqdm_kwargsr1r )rZ tqdm_kwargsr-r r;Zexcer2r r r Ös ÿþ zTqdmCallback.__init__cCs|jjfd|i|j—Ž|_dS)NÚtotal)r<r;r>rr r r rãszTqdmCallback.set_sizercCs|j |¡dSr)r;rrr r r ræszTqdmCallback.relative_updatecCs|j ¡d|_dSr)r;Úclose)rr r r Ú__del__és zTqdmCallback.__del__)N)r) r'r(r)r*r rrrAr9r r r2r r:´s !  r:N)rr,r.r:r$r r r r Ús  :