DaskManager can't handle list[Future]

[cobra91]

if we put this DaskManager().compute(res_compare) where res_compare is a append list of task that can't work !

[ahirner]

If the list to append to isn't thread save or a distributed structure, surely. Did you see that in the repo somewhere?

[cobra91]

`class DaskManager(metaclass=Singleton):
def init(self):
self.client = Client(f'{settings.DASK_SCHEDULER_HOST}:{settings.DASK_SCHEDULER_PORT}')

def compute(self, graph):
    future = self.client.compute(graph)
    future.add_done_callback(self.task_complete)
    dask_task = DaskTask.objects.create(task_key=future.key)
    return dask_task`

Here compute work but crash on call to add_done_callback because future can be a list[Future]