a tDf@svddlmZddlmZddlmZddlmZddgZGdddZ dd Z edd d Z d dZ GdddZ d S)) annotations)Callable)contextmanager)ClassVarCallback add_callbacksc@sheZdZUdZeZded<dddZeddd d Z d d Z d dZ ddddZ ddddZ dS)raBase class for using the callback mechanism Create a callback with functions of the following signatures: >>> def start(dsk): ... pass >>> def start_state(dsk, state): ... pass >>> def pretask(key, dsk, state): ... pass >>> def posttask(key, result, dsk, state, worker_id): ... pass >>> def finish(dsk, state, failed): ... pass You may then construct a callback object with any number of them >>> cb = Callback(pretask=pretask, finish=finish) And use it either as a context manager over a compute/get call >>> with cb: # doctest: +SKIP ... x.compute() Or globally with the ``register`` method >>> cb.register() >>> cb.unregister() Alternatively subclass the ``Callback`` class with your own methods. >>> class PrintKeys(Callback): ... def _pretask(self, key, dask, state): ... print("Computing: {0}!".format(repr(key))) >>> with PrintKeys(): # doctest: +SKIP ... x.compute() z*ClassVar[set[tuple[Callable | None, ...]]]activeNcCs6|r ||_|r||_|r||_|r(||_|r2||_dSN_startZ _start_stateZ_pretaskZ _posttaskZ_finish)selfstartZ start_stateZpretaskZposttaskfinishr[/nfs/NAS7/SABIOD/METHODE/ermites/ermites_venv/lib/python3.9/site-packages/dask/callbacks.py__init__4szCallback.__init__ztuple[Callable | None, ...])returncsgd}tfdd|DS)Nr c3s|]}t|dVqdSr )getattr.0ir rr Ez%Callback._callback..)tuple)r fieldsrrr _callbackBszCallback._callbackcCst||_|j|Sr )r_cm __enter__rrrrrGs  zCallback.__enter__cGs|jj|dSr )r__exit__)r argsrrrrLszCallback.__exit__NonecCstj|jdSr )rraddrrrrrregisterOszCallback.registercCstj|jdSr )rrremoverrrrr unregisterRszCallback.unregister)NNNNN)__name__ __module__ __qualname____doc__setr__annotations__rpropertyrrrr#r%rrrrr s ' cCs"|rddt|DSgdSdS)z>Take an iterable of callbacks, return a list of each callback.cSsg|]}dd|DqS)cSsg|] }|r|qSrrrrrr Yrz/unpack_callbacks...r)rfrrrr-Yrz$unpack_callbacks..)rrrrrN)zip)Zcbsrrrunpack_callbacksVsr0NccsF|du}|rtjt}t_z|p$dVW|rB|t_n |r@|t_0dS)zAllows callbacks to work with nested schedulers. Callbacks will only be used by the first started scheduler they encounter. This means that only the outermost scheduler will use global callbacks.Nr)rrr*) callbacksZglobal_callbacksrrrlocal_callbacks^s r2cCs*t|tr|jSt|tr|StddS)z Normalizes a callback to a tuplez.Callbacks must be either `Callback` or `tuple`N) isinstancerrr TypeError)cbrrrnormalize_callbackns   r6c@s(eZdZdZddZddZddZdS) raContext manager for callbacks. Takes several callbacks and applies them only in the enclosed context. Callbacks can either be represented as a ``Callback`` object, or as a tuple of length 4. Examples -------- >>> def pretask(key, dsk, state): ... print("Now running {0}").format(key) >>> callbacks = (None, pretask, None, None) >>> with add_callbacks(callbacks): # doctest: +SKIP ... res.compute() cGs"dd|D|_tj|jdS)NcSsg|] }t|qSr)r6)rcrrrr-rz*add_callbacks.__init__..)r1rrupdate)r r1rrrrszadd_callbacks.__init__cCsdSr rrrrrrszadd_callbacks.__enter__cCs|jD]}tj|qdSr )r1rrdiscard)r typevalue tracebackr7rrrrs zadd_callbacks.__exit__N)r&r'r(r)rrrrrrrrxs)N) __future__rcollections.abcr contextlibrtypingr__all__rr0r2r6rrrrrs    L