Can I recover from a computed Future the original arguments I passed to a delayed function?

Distributed
1

I submit a lot of tasks with some randomness in the input, but I would like to be able to retrace the original input numbers without necessary attaching it manually to each delayed function. Is there any way I can ask a future for the original input?

I noticed that UUID keys are generated when I submit tasks to my cluster. I understand that I can keep the mapping that way alternatively.

2

Hi @bieniekmat, welcome to Dask community,

Unfortunately, as stated in this Stackoverflow question:

Futures don’t hold onto their inputs. You can do this yourself though.

futures = {}
future = client.submit(func, *args)

futures[future] = args
1 Like