UnboundLocalError с потоковой передачей Dask через holoviews - PullRequest
Новая
       50

UnboundLocalError с потоковой передачей Dask через holoviews

0 голосов
/ 24 апреля 2020

Может ли кто-нибудь помочь мне, почему происходит ошибка с UnboundLocalError

s = streamz.Stream()
s.scatter().map(transform).map(plot).map(dask.compute).gather()

example = pd.DataFrame({'DayOfWeek': [], "Distance": []})
sdf = streamz.DataFrame(s, example=dd.from_pandas(example, npartitions=10))

holoviews.DynamicMap(partial(hv.Scatter, kdims=["DayOfWeek", "Distance"], vdims=["DayOfWeek", "Distance"]), streams=[Buffer(sdf)]) #placeholder1

# in a new Jupyter cell
s.emit(dd.read_parquet(...))

Я надеялся увидеть график рассеяния в ячейке # placeholder1 выше. Но я получаю 

<SOME_PATH>/python3.7/site-packages/holoviews/streams.py in _concat(self, data)
    599                     new_data[k] = v
    600             data = new_data
--> 601         self._chunk_length = data_length
    602         return data
    603 

UnboundLocalError: local variable 'data_length' referenced before assignment

Общий полный пример на https://colab.research.google.com/drive/1rtPcJmq6DJOatKkLFJTVOgFDqL-FOzQx#scrollTo = UrTHe8Ajp4Wj & line = 1 & uniqifier = 1

_

...