I am using the Dask submit and gather paradigm to do something like:
data_future = client.scatter(data, broadcast=True)
futures = []
for i in range(10):
futures.append(dask.submit(some_func, i, data_future))
results = dask_client.gather(futures)
Is there some way to view/visualize the DAG in this paradigm after the computation has completed?
The documentation appears to be well suited for the Dask delayed paradigm. In case it matters, this is for a distributed cluster.