Hi friends~
Currently if I have a delayed function that’s named f3, it shows on the dashboard which is nice. However, since it’s possible to have many tasks of different jobs running in parallel, Im thinking if this label is customizable, e.g. job-foo: f3
@ubw218 Thanks for your question! With Delayed objects, you can use the dask_key_name parameter to customize that key. Ref docs: API — Dask documentation
from dask import delayed
from distributed import Client
client = Client()
@delayed
def inc(x):
return x + 1
inc(20, dask_key_name='unique_dask_key_name').compute()
1 Like