Why does dask return a subgraph rather than a computation on read_csv().compute()?

Viewed 43

When I do dd.read_csv('AAPL.csv'), it correctly identifies the structure:

In [13]: dd.read_csv('AAPL.csv')
Out[13]:
Dask DataFrame Structure:
              2016-01-04T09:00:00Z   105.45 105.45.1    103.6  103.6.1    17462
npartitions=1
                            object  float64  float64  float64  float64  float64
                               ...      ...      ...      ...      ...      ...
Dask Name: read-csv, 1 tasks

But when I try to actually compute it, it always returns this:

In [14]: dd.read_csv('AAPL.csv').compute()
Out[14]: 
0    (<Serialize: subgraph_callable-f9057ef2-07c7-4...
dtype: object

It works fine when importing with pandas. What am I doing wrong?

0 Answers
Related