o Nrf@svddlmZddlmZddlmZddlmZddgZGdddZ dd Z edd d Z d dZ GdddZ d S)) annotations)Callable)contextmanager)ClassVarCallback add_callbacksc@s^eZdZUdZeZded< dddZedd d Z d d Z d dZ dddZ dddZ 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, ...]]]activeNcCs:|r||_|r ||_|r||_|r||_|r||_dSdSN_startZ _start_stateZ_pretaskZ _posttaskZ_finish)selfstartZ start_stateZpretaskZposttaskfinishrW/var/www/html/software/conda/envs/catlas/lib/python3.10/site-packages/dask/callbacks.py__init__4s zCallback.__init__returntuple[Callable | None, ...]csgd}tfdd|DS)Nr c3s|] }t|dVqdSr )getattr.0ir rr Esz%Callback._callback..)tuple)r fieldsrrr _callbackBszCallback._callbackcCst||_|j|Sr )r_cm __enter__rrrrrGs  zCallback.__enter__cGs|jj|dSr )r__exit__)r argsrrrrLszCallback.__exit__NonecCtj|jdSr )rraddrrrrrregisterOzCallback.registercCr"r )rrremoverrrrr unregisterRr%zCallback.unregister)NNNNN)rr)rr!)__name__ __module__ __qualname____doc__setr__annotations__rpropertyrrrr$r'rrrrr s '   cCs|r ddt|DSgdS)z>Take an iterable of callbacks, return a list of each callback.cSsg|] }dd|DqS)cSsg|]}|r|qSrrrrrr Yz/unpack_callbacks...r)rfrrrr/Ysz$unpack_callbacks..)rrrrr)zip)Zcbsrrrunpack_callbacksVsr3NccsJ|du}|rtjt}t_z|pdVW|r|t_dSdS|r$|t_w)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  r5cCs&t|tr|jSt|tr|Std)z Normalizes a callback to a tuplez.Callbacks must be either `Callback` or `tuple`) isinstancerrr TypeError)cbrrrnormalize_callbackns  r9c@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)r9)rcrrrr/r0z*add_callbacks.__init__..)r4rrupdate)r r4rrrrszadd_callbacks.__init__cCsdSr rrrrrrszadd_callbacks.__enter__cCs|jD]}tj|qdSr )r4rrdiscard)r typevalue tracebackr:rrrrs zadd_callbacks.__exit__N)r(r)r*r+rrrrrrrrxs  r ) __future__rcollections.abcr contextlibrtypingr__all__rr3r5r9rrrrrs   L