We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fc3db09 commit 14f4d71Copy full SHA for 14f4d71
1 file changed
streamz/dataframe/core.py
@@ -846,8 +846,8 @@ class PeriodicDataFrame(DataFrame):
846
datafn: callable
847
Callback function accepting **kwargs and returning a
848
pd.DataFrame. kwargs will include at least
849
- 'last' (time.time() datafn was last invoked), and
850
- 'now' (current time.time()).
+ 'last' (pd.Timestamp.now() when datafn was last invoked), and
+ 'now' (current pd.Timestamp.now()).
851
interval: timedelta
852
The time interval between new dataframes.
853
dask: boolean
0 commit comments