>ieddlmZddlmZddlmZddlmZddgZGddZ dZ ed d Z d Z Gd dZ d S)) annotations)Callable)contextmanager)ClassVarCallback add_callbackscpeZdZUdZeZded< ddZeddZ d Z d Z dd Z dd Z 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, ...]]]activeNcd|r||_|r||_|r||_|r||_|r ||_dSdSN_start _start_state_pretask _posttask_finish)selfstart start_statepretaskposttaskfinishs .lib/python3.11/site-packages/dask/callbacks.py__init__zCallback.__init__4s^  DK  , +D   $#DM  &%DN  "!DLLL " "returntuple[Callable | None, ...]cBgd}tfd|DS)Nr c3:K|]}t|dVdSr )getattr).0irs r z%Callback._callback..Es/<<WT1d++<<<<<>>>QU " " " "===X= !!!,,,,//////rc4|rdt|DSgdS)z>Take an iterable of callbacks, return a list of each callback.c&g|]}d|DS)cg|]}||Sr<r<)r!r"s r z/unpack_callbacks...Ys###q####rr<)r!fs rr@z$unpack_callbacks..Ys'777##A###777r)r<r<r<r<r<)zip)cbss runpack_callbacksrDVs. $77S#Y7777####rNc#K|du}|r%tjtc}t_ |pdV|r|t_dSdS#|r |t_wxYw)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 r9) callbacksglobal_callbackss rlocal_callbacksrH^s} !D(<%-_cee" 8?(o2  ('HOOO ( (  ('HO ' ' ' 's AAct|tr|jSt|tr|St d)z Normalizes a callback to a tuplez.Callbacks must be either `Callback` or `tuple`) isinstancerr&r$ TypeError)cbs rnormalize_callbackrMnsD"hJ| B  J HIIIrc$eZdZdZdZdZdZdS)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() cpd|D|_tj|jdS)Nc,g|]}t|Sr<)rM)r!cs rr@z*add_callbacks.__init__..s!CCCA,Q//CCCr)rFrr update)rrFs rrzadd_callbacks.__init__s5CCCCCt~.....rcdSr r<r*s rr)zadd_callbacks.__enter__srcX|jD]!}tj|"dSr )rFrr discard)rtypevalue tracebackrQs rr,zadd_callbacks.__exit__s6 ' 'A O # #A & & & & ' 'rN)r5r6r7r8rr)r,r<rrrrxsK  ///'''''rr ) __future__rcollections.abcr contextlibrtypingr__all__rrDrHrMrr<rrr^s""""""$$$$$$%%%%%%  'I/I/I/I/I/I/I/I/X$$$ ( ( ( (JJJ''''''''''r