diff --git a/data_juicer/core/ray_executor.py b/data_juicer/core/ray_executor.py
index 1c066ea02..9a0e0835b 100644
--- a/data_juicer/core/ray_executor.py
+++ b/data_juicer/core/ray_executor.py
@@ -155,6 +155,8 @@ def run_op(self, op, op_cfg, dataset):
                     'Ray executor only support Filter and Mapper OPs for '
                     'now')
                 raise NotImplementedError
+
+            return dataset
         except:  # noqa: E722
             logger.error(f'An error occurred during Op [{op_name}].')
             import traceback