'DataFrame' object has no attribute 'to_delayed'?
I am using randomforest model from scikit learn and BlockwisevottingRegressor from dask.
Code:
Error:
Solution
The problem stems from the lines:
Xs = X.to_delayed()
ys = y.to_delayed()
The .to_delayed() method is defined for dask DataFrames and dask Arrays, but not for pandas or numpy objects. It's likely that the labels X and y are associated with a pandas DataFrame.
In the error traceback image, the AttributeError suggests that the object is a pandas DataFrame (possibly another library's DataFrame, but most likely a pandas one).
Not much more can be derived from the image posted.
- Dask - How to cancel and resubmit stalled tasks?
- How to set up logging on dask distributed workers?
- Using Dask on an apply returning several columns (a DataFrame so)
- How to efficiently parallelize time series forecasting using dask?
- xarray and dask: efficiently processing a large netcdf file
- How to accelerate getting points within distance using two DataFrames?
- dask map_partitions strange behaviour
- How can I keep Dask workers busy when processing large datasets to prevent them from running out of tasks?
- Dask dataframe running parallel and partitioned by columns
- Unable to install Dask in Azure Databricks
- Server Side Encryption in to_csv function
- Build a combined column in dask dataframe for sorting
- How to export dask HTML high level graph to disk
- How to handle large xarray/dask datasets to minimize computation time or running out of memory to store as yearly files (ERA5 dataset)
- How to see progress of Dask compute task?
- dask error when trying to modify categorical data
- Sampling n= 2000 from a Dask Dataframe of len 18000 generates error Cannot take a larger sample than population when 'replace=False'
- Connecting to Delta Lake hosted on MinIO from Dask
- Extracting SQL Server table data to parquet file
- Dask - How to optimize the computation of the first row of each partition in a dask dataframe?
- How to Handle Individual Worker Failures in Dask When Running Simulations on an HTCondor Cluster?
- How to use user-defined fsspec filesystem with dask?
- What is the cleanest way to detect whether I'm running in a dask Worker
- Understanding task stream and speeding up Distributed Dask
- unicode error when using dask.dataframe.read_csv
- Dealing with a very large xarray dataset: loading slices consuming too much time
- Dask set dtype to an array of integers
- Dask nanny memory error - Worker is too slow to terminate
- How to show all the data from my dask array in python?
- Default n_workers when creating a Dask cluster?