Handle streamz 0.3.0 API changes
@@ -430,6 +430,10 @@ class Buffer(Pipe):
try:
from streamz.dataframe import StreamingDataFrame, StreamingSeries
loaded = True
+ except ImportError:
+ try:
+ from streamz.dataframe import DataFrame as StreamingDataFrame, Series as StreamingSeries
+ loaded = True
except ImportError:
loaded = False
if not loaded or not isinstance(data, (StreamingDataFrame, StreamingSeries)):
