LgddlmZddlmZddlmZddlmZddgZGddZ dZ ed d Z d Z Gd dZ y )) annotations)Callable)contextmanager)ClassVarCallback add_callbackscbeZdZUdZeZded< d dZed dZ dZ dZ d d Z d d Z y)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, ...]]]activeNc`|r||_|r||_|r||_|r||_|r||_yyN_start _start_state_pretask _posttask_finish)selfstart start_statepretaskposttaskfinishs .lib/python3.12/site-packages/dask/callbacks.py__init__zCallback.__init__4s< DK  +D  #DM %DN !DL c4gd}tfd|DS)Nr c38K|]}t|dywr )getattr).0irs r z%Callback._callback..EsQU "== !,/rcv|r)t|Dcgc]}|Dcgc]}|s| c}c}}SgdScc}wcc}}w)z>Take an iterable of callbacks, return a list of each callback.)r;r;r;r;r;)zip)cbsfr s runpack_callbacksr@Vs= -0#Y7YA#AqA#Y77##$7s 50 0 55Nc#K|du}|r$tjtc}t_ |xsd|r |t_yy#|r |t_wwxYww)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;)rr r8) callbacksglobal_callbackss rlocal_callbacksrD^sX !D(%-__ce" 8?(o2 'HO  'HO s+AAAAActt|tr |jSt|tr|St d)z Normalizes a callback to a tuplez.Callbacks must be either `Callback` or `tuple`) isinstancerr$r" TypeError)cbs rnormalize_callbackrIns1"h|| B  HIIrc"eZdZdZdZdZdZy)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() c|Dcgc] }t|c}|_tjj |jycc}wr )rIrBrr update)rrBcs rrzadd_callbacks.__init__s:9BCA,Q/Ct~~.DsA cyr r;r(s rr'zadd_callbacks.__enter__srcd|jD]!}tjj|#yr )rBrr discard)rtypevalue tracebackrMs rr*zadd_callbacks.__exit__s"A OO # #A & rN)r4r5r6r7rr'r*r;rrrrxs /'rr ) __future__rcollections.abcr contextlibrtypingr__all__rr@rDrIrr;rrrYsQ"$%  'I/I/X$ ( (J''r