Merge pull request #75 from timeflux/fix-deprecated-warning

Use pd.concat instead of deprecated Dataframe.append
timeflux · Sep 23, 2022 · f427aa7 · f427aa7
2 parents 51ae887 + 5cd170c
commit f427aa7
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/timeflux/nodes/dejitter.py b/timeflux/nodes/dejitter.py
@@ -183,7 +183,7 @@ def _interpolate(self):
             [self._buffer, self.i.data], sort=True
         )  # append last sample be able to interpolate
 
-        if not self._buffer.index.is_monotonic:
+        if not self._buffer.index.is_monotonic_increasing:
             self.logger.warning("Data index should be strictly monotonic")
             self._buffer = self._make_monotonic(self._buffer)
 

diff --git a/timeflux/nodes/epoch.py b/timeflux/nodes/epoch.py
@@ -60,7 +60,7 @@ def update(self):
                 low = index - self._before
                 high = index + self._after
                 if self._buffer is not None:
-                    if not self._buffer.index.is_monotonic:
+                    if not self._buffer.index.is_monotonic_increasing:
                         self.logger.warning("Index must be monotonic. Skipping epoch.")
                         return
                     try:

diff --git a/timeflux/nodes/window.py b/timeflux/nodes/window.py
@@ -196,7 +196,7 @@ def update(self):
         if self._buffer is None:
             self._buffer = self.i.data
         else:
-            self._buffer = self._buffer.append(self.i.data)
+            self._buffer = pd.concat([self._buffer, self.i.data])
 
         # Make sure we have enough data
         if len(self._buffer) >= self._length: