CODEWITHSUNDEEP
pythonpandasdask
somer somer
somer somer

Reputation: 33

How to unpack a dataframe of delayed dask objects?

I have used the .map_partitions with delayed functions and the result I got is a dataframe with delayed results in each row.

Is there any way to unpack those delayed objects? Am I doing something wrong?

Thank you.

Upvotes: 1

Views: 100

Answers (1)

mdurant
mdurant

Reputation: 28673

A very short answer: you should use map_partitions with a normal function, not a delayed one. The dataframe interface already provides laziness and parallelism, so you don't need to add another nested level.

Upvotes: 5

Related Questions