Python Channel

I'm having some probems apllying a text search algorithm with parallelized dask insfrastructure… Read more Having Problemns While Using Dask Map_partitions With String Matching Algorithm

I am reading NetCDF files using xarray. Each variable have 4 dimensions (Times, lev, y, x). After r… Read more Plotting 2d Data Using Xarray Takes A Surprisingly Long Time?

tl;dr I want to dd.read_parquet('*.parq')['column'].nunique().compute() but I get … Read more Dask Dataframe Nunique Operation: Worker Running Out Of Memory (mre)

I need help about a problem that I'm pretty sure dask can solve. But I don't know how to ta… Read more Parallelize Tree Creation With Dask

If I have an mutable object, let's say for example a dict, how does dask handle passing that as… Read more How Does Dask.delayed Handle Mutable Inputs?

Is this a valid way of loading subsets of a dask dataframe to memory: while i len_df: j =… Read more Subsetting Dask Dataframes

I'm trying to save by Dask Dataframe to parquet on the same machine as the dask scheduler/worke… Read more How To Save Dask Dataframe To Parquet On Same Machine As Dask Sheduler/workers?

I'm trying to process a fairly large dataset that doesn't fit into memory using Pandas when… Read more What Is The Way To Add An Index Column In Dask When Reading From A Csv?