MCPcopy
hub / github.com/dask/dask / MyCallback

Class MyCallback

dask/tests/test_callbacks.py:14–16  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

12 flag = [False]
13
14 class MyCallback(Callback):
15 def _start(self, dsk):
16 flag[0] = True
17
18 with MyCallback():
19 get_sync({"x": 1}, "x")

Callers 4

test_start_callbackFunction · 0.85
test_start_state_callbackFunction · 0.85
test_finish_always_calledFunction · 0.85
test_nested_schedulersFunction · 0.85

Calls

no outgoing calls

Tested by 4

test_start_callbackFunction · 0.68
test_start_state_callbackFunction · 0.68
test_finish_always_calledFunction · 0.68
test_nested_schedulersFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…