diff --git a/beat/backend/python/data.py b/beat/backend/python/data.py
index 77b443f243c9a498772ce95811421595101abaa1..572d290a711473f9a9bfb13323dedf6cb6986968 100755
--- a/beat/backend/python/data.py
+++ b/beat/backend/python/data.py
@@ -941,7 +941,7 @@ class CachedDataSink(DataSink):
             self.index_file = None
             self.last_written_data_index = None
 
-            return True
+        return True
 
 
     def __del__(self):