Example:
importosimportpandasimportshutilfromexecutorlibimportExecutorfromexecutorlib.standalone.hdfimportget_cache_datacache_directory="./cache"withExecutor(backend="local", cache_directory=cache_directory) asexe:
future_lst= [exe.submit(sum, [i, i]) foriinrange(1, 4)]
print([f.result() forfinfuture_lst])
df=pandas.DataFrame(get_cache_data(cache_directory=cache_directory))
df
This was implemented in #525
Example:
This was implemented in #525